move code examples to code_example folder

dagster-io · Aug 16, 2024 · 7235e58 · 7235e58
1 parent c55b3f5
commit 7235e58
Show file tree

Hide file tree

Showing 9 changed files with 88 additions and 36 deletions.
diff --git a/docs/docs-next/docs/code_examples/guides/automation/asset-sensor-with-config.py b/docs/docs-next/docs/code_examples/guides/automation/asset-sensor-with-config.py
@@ -0,0 +1,52 @@
+from dagster import (
+    AssetExecutionContext,
+    AssetKey,
+    Definitions,
+    EventLogEntry,
+    RunRequest,
+    SensorEvaluationContext,
+    asset,
+    asset_sensor,
+    define_asset_job,
+)
+
+
+@asset
+def daily_sales_data(context: AssetExecutionContext):
+    context.log.info("Asset to watch")
+
+
+@asset
+def weekly_report(context: AssetExecutionContext):
+    context.log.info("Asset to trigger")
+
+
+my_job = define_asset_job("my_job", [weekly_report])
+
+
+# highlight-start
+@asset_sensor(asset_key=AssetKey("daily_sales_data"), job=my_job)
+def daily_sales_data_sensor(context: SensorEvaluationContext, asset_event: EventLogEntry):
+    # This satisifies the type checker. Asset events are guaranteed to have a dagster_event and asset_key.
+    assert asset_event.dagster_event is not None
+    assert asset_event.dagster_event.asset_key is not None
+
+    return RunRequest(
+        run_key=context.cursor,
+        run_config={
+            "ops": {
+                "read_materialization": {
+                    "config": {
+                        "asset_key": asset_event.dagster_event.asset_key.path,
+                    }
+                }
+            }
+        },
+    )  # highlight-end
+
+
+defs = Definitions(
+    assets=[daily_sales_data, weekly_report],
+    jobs=[my_job],
+    sensors=[daily_sales_data_sensor],
+)
diff --git a/docs/docs-next/docs/code_examples/guides/automation/simple-asset-sensor-example.py b/docs/docs-next/docs/code_examples/guides/automation/simple-asset-sensor-example.py
@@ -0,0 +1,36 @@
+from dagster import (
+    AssetExecutionContext,
+    AssetKey,
+    Definitions,
+    RunRequest,
+    asset,
+    asset_sensor,
+    define_asset_job,
+)
+
+
+@asset
+def daily_sales_data(context: AssetExecutionContext):
+    context.log.info("Asset to watch")
+
+
+@asset
+def weekly_report(context: AssetExecutionContext):
+    context.log.info("Asset to trigger")
+
+
+my_job = define_asset_job("my_job", [weekly_report])
+
+
+# highlight-start
+@asset_sensor(asset_key=AssetKey("daily_sales_data"), job_name="my_job")
+def daily_sales_data_sensor():
+    return RunRequest()
+    # highlight-end
+
+
+defs = Definitions(
+    assets=[daily_sales_data, weekly_report],
+    jobs=[my_job],
+    sensors=[daily_sales_data_sensor],
+)
diff --git a/...des/automation/simple-schedule-example.py → ...des/automation/simple-schedule-example.py b/...des/automation/simple-schedule-example.py → ...des/automation/simple-schedule-example.py
diff --git a/...uides/automation/simple-sensor-example.py → ...uides/automation/simple-sensor-example.py b/...uides/automation/simple-sensor-example.py → ...uides/automation/simple-sensor-example.py
diff --git a/...passing-data-assets/passing-data-avoid.py → ...passing-data-assets/passing-data-avoid.py b/...passing-data-assets/passing-data-avoid.py → ...passing-data-assets/passing-data-avoid.py
diff --git a/...sing-data-assets/passing-data-explicit.py → ...sing-data-assets/passing-data-explicit.py b/...sing-data-assets/passing-data-explicit.py → ...sing-data-assets/passing-data-explicit.py
diff --git a/...ng-data-assets/passing-data-io-manager.py → ...ng-data-assets/passing-data-io-manager.py b/...ng-data-assets/passing-data-io-manager.py → ...ng-data-assets/passing-data-io-manager.py
diff --git a/...ata-assets/passing-data-rewrite-assets.py → ...ata-assets/passing-data-rewrite-assets.py b/...ata-assets/passing-data-rewrite-assets.py → ...ata-assets/passing-data-rewrite-assets.py
diff --git a/docs/docs-next/docs/guides/automation/simple-asset-sensor-example.py b/docs/docs-next/docs/guides/automation/simple-asset-sensor-example.py