shailesh
11/22/2022, 1:03 PMSean Lopp
11/22/2022, 2:51 PMSourceAsset
in A:
https://github.com/slopp/dagteam/blob/main/ml_project/ml_project/repository.py#L8-L14shailesh
11/22/2022, 2:59 PM@sensor(job=sensor_job)
def transform_run_sensor(context):
run_records = context.instance.get_run_records(
filters=RunsFilter(
job_name=f"test_data_elt",
statuses=[PipelineRunStatus.SUCCESS]
),
order_by="update_timestamp",
ascending=False,
)
# here ob_name=f"test_data_elt" is the job name of repository A
Sean Lopp
11/22/2022, 4:11 PM