D Zavadskykh
08/31/2023, 4:46 AM@run_status_sensor(
run_status=DagsterRunStatus.SUCCESS,
request_job=<request_job>,
default_status=DefaultSensorStatus.RUNNING
)
def <sensor_name>(context):
if context.dagster_run.job_name == dbt_assets_job.name:
return RunRequest(run_key=None)
else:
return SkipReason("Run only after successful <job_name> job")
sandy
08/31/2023, 1:34 PMD Zavadskykh
08/31/2023, 1:49 PMsandy
08/31/2023, 9:49 PM