Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
2241000 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 18:00:00+00:00')] | |
2240999 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 04:05:00+00:00'), ('run_id', 'scheduled__2024-06-30T04:05:00+00:00')] | |
2240998 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T19:00:00+00:00'), ('task_id', 'check_cluster_status')] |
2240997 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-30 00:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T00:00:00+00:00')] | |
2240996 |
|
livepop-shuffle-job_v002 | tree |
|
anonymous | [('dag_id', 'livepop-shuffle-job_v002')] | |
2240995 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T00:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')] | |
2240994 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 12:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T12:00:00+00:00')] | |
2240993 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T06:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240992 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T12:00:00+00:00'), ('root', 'check_cluster_status')] | |
2240991 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 21:00:00+00:00')] | |
2240990 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 12:05:00+00:00')] | |
2240989 |
|
primary-audience-global_v003 | gantt |
|
anonymous | [('dag_id', 'primary-audience-global_v003')] | |
2240988 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T04:00:00+00:00'), ('root', 'check_cluster_status')] | |
2240987 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T14:00:00+00:00'), ('task_id', 'check_cluster_status')] |
2240986 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T13:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240985 |
|
exchange-daily-revenue-report_v002 | graph |
|
anonymous | [('dag_id', 'exchange-daily-revenue-report_v002')] | |
2240984 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 14:05:00+00:00'), ('run_id', 'scheduled__2024-06-29T14:05:00+00:00')] | |
2240983 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T21:00:00+00:00'), ('task_id', 'create_emr_steps')] |
2240982 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02 14:00:00+00:00')] | |
2240981 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 22:00:00+00:00')] | |
2240980 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T03:00:00+00:00'), ('root', 'check_cluster_status')] | |
2240979 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T05:00:00+00:00'), ('root', 'create_emr_steps')] | |
2240978 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T07:00:00+00:00'), ('root', 'check_cluster_status')] | |
2240977 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 08:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T08:00:00+00:00')] | |
2240976 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 13:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T13:00:00+00:00')] | |
2240975 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 03:00:00+00:00')] | |
2240974 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T12:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240973 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 01:05:00+00:00')] | |
2240972 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-29 19:05:00+00:00'), ('run_id', 'scheduled__2024-06-29T19:05:00+00:00')] | |
2240971 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 03:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T03:00:00+00:00')] | |
2240970 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06 02:00:00+00:00')] | |
2240969 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T10:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240968 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T21:00:00+00:00'), ('root', 'check_cluster_status')] | |
2240967 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-30 02:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T02:00:00+00:00')] | |
2240966 |
|
booking-processing-job_v002 | gantt |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
2240965 |
|
exchange-daily-revenue-report_v002 | tries |
|
anonymous | [('dag_id', 'exchange-daily-revenue-report_v002')] | |
2240964 |
|
booking-sync-report_v002 | landing_times |
|
anonymous | [('dag_id', 'booking-sync-report_v002')] | |
2240963 |
|
vc-asset-import_v002 | tree |
|
anonymous | [('dag_id', 'vc-asset-import_v002')] | |
2240962 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-30 11:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T11:00:00+00:00')] | |
2240961 |
|
primary-audience-global_v003 | trigger |
|
anonymous | [('dag_id', 'primary-audience-global_v003'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')] | |
2240960 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T02:00:00+00:00'), ('root', 'create_emr_steps')] | |
2240959 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T02:00:00+00:00'), ('task_id', 'check_cluster_status')] |
2240958 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 08:00:00+00:00'), ('run_id', 'scheduled__2024-06-30T08:00:00+00:00')] | |
2240957 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | log |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T01:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240956 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T07:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')] | |
2240955 |
|
campaign-versioning-job_v002 | tree |
|
anonymous | [('dag_id', 'campaign-versioning-job_v002')] | |
2240954 |
|
exchange-trade-summary_v1_v002 | duration |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002')] | |
2240953 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-30 01:00:00+00:00')] | |
2240952 |
|
Custom-EMR-cluster_v001 | gantt |
|
anonymous | [('dag_id', 'Custom-EMR-cluster_v001')] | |
2240951 |
|
Custom-EMR-cluster_v001 | graph |
|
anonymous | [('dag_id', 'Custom-EMR-cluster_v001')] | |
2240950 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002')] | |
2240949 |
|
booking-processing-job_v002 | landing_times |
|
anonymous | [('dag_id', 'booking-processing-job_v002')] | |
2240948 |
|
primary-audience-global-masterdb_v003 | landing_times |
|
anonymous | [('dag_id', 'primary-audience-global-masterdb_v003')] | |
2240947 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T21:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240946 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-02T13:00:00+00:00'), ('root', 'create_emr_steps')] | |
2240945 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 20:00:00+00:00')] | |
2240944 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-29 15:00:00+00:00')] | |
2240943 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-29 21:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T21:00:00+00:00')] | |
2240942 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 08:05:00+00:00'), ('run_id', 'scheduled__2024-06-30T08:05:00+00:00')] | |
2240941 |
|
livepop-shuffle-job_v002 | gantt |
|
anonymous | [('dag_id', 'livepop-shuffle-job_v002')] | |
2240940 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06 23:00:00+00:00')] | |
2240939 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T20:00:00+00:00'), ('root', 'create_emr_steps')] | |
2240938 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-06T22:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240937 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | task |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T21:00:00+00:00'), ('task_id', 'create_emr_steps')] |
2240936 |
|
vc-asset-import_v002 | graph |
|
anonymous | [('dag_id', 'vc-asset-import_v002'), ('execution_date', '2024-06-30 11:05:00+00:00')] | |
2240935 |
|
primary-audience-global_v003 | tries |
|
anonymous | [('dag_id', 'primary-audience-global_v003')] | |
2240934 |
|
Custom-EMR-cluster_v001 | trigger |
|
anonymous | [('dag_id', 'Custom-EMR-cluster_v001'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')] | |
2240933 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240932 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | running |
|
data.engineers@viooh.com | |
2240931 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240930 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-06-29 21:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T21:00:00+00:00')] | |
2240929 |
|
campaign-delta-past-delete-job_v002 | trigger |
|
anonymous | [('dag_id', 'campaign-delta-past-delete-job_v002'), ('origin', 'https://airflow.devel.viooh.net.cn/admin/')] | |
2240928 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
2240927 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240926 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
2240925 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240924 |
|
exchange-trade-summary_v1_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2240923 |
|
exchange-trade-summary_v1_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
2240922 |
|
exchange-trade-summary_v1_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2240921 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_cluster_and_add_emr_steps | log |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T08:00:00+00:00'), ('task_id', 'create_cluster_and_add_emr_steps')] |
2240920 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | log |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-01T21:00:00+00:00'), ('task_id', 'create_emr_steps')] |
2240919 |
|
exchange-trade-summary_v1_v002 | graph |
|
anonymous | [('dag_id', 'exchange-trade-summary_v1_v002'), ('execution_date', '2024-06-06T13:00:00+00:00'), ('root', 'create_emr_steps')] | |
2240918 |
|
booking-by-hour-model-transform_v002 | tries |
|
anonymous | [('dag_id', 'booking-by-hour-model-transform_v002')] | |
2240917 |
|
Custom-EMR-cluster_v001 | tree |
|
anonymous | [('dag_id', 'Custom-EMR-cluster_v001')] | |
2240916 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | success |
|
data.engineers@viooh.com | |
2240915 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240914 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | running |
|
data.engineers@viooh.com | |
2240913 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-29 22:00:00+00:00'), ('run_id', 'scheduled__2024-06-29T22:00:00+00:00')] | |
2240912 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240911 |
|
cli_serve_logs |
|
airflow | {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"} | ||
2240910 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
2240909 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-06-07T02:00:00+00:00'), ('root', 'create_cluster_and_add_emr_steps')] | |
2240908 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2240907 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
2240906 |
|
cli_worker |
|
airflow | {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"} | ||
2240905 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2240904 |
|
exchange-trade-summary_v1_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
2240903 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | success |
|
data.engineers@viooh.com | |
2240902 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2240901 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | running |
|
data.engineers@viooh.com |