add row count

dagster-io · Sep 20, 2024 · b75da24 · b75da24
1 parent 6508c7a
commit b75da24
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hooli-demo-assets/hooli_demo_assets/assets/sling.py b/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).fetch_column_metadata()
+   yield from sling.replicate(context=context).fetch_column_metadata().fetch_row_count()
    for row in sling.stream_raw_logs():
        context.log.info(row)