Merge pull request #125 from dagster-io/sling-column-updates

add column metadata and lineage to sling

hooli-demo-assets/hooli_demo_assets/assets/sling.py

@@ -29,6 +29,6 @@ def get_tags(self, stream_definition):
    dagster_sling_translator=CustomSlingTranslator(),
 )
 def my_sling_assets(context, sling: SlingResource):
-   yield from sling.replicate(context=context)
+   yield from sling.replicate(context=context).fetch_column_metadata().fetch_row_count()
    for row in sling.stream_raw_logs():
        context.log.info(row)