Id | Dttm | Dag Id | Task Id | Event | Execution Date | Owner | Extra |
---|---|---|---|---|---|---|---|
2930063 |
|
exchange-trade-summary_v1_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
2930062 |
|
exchange-trade-summary_v1_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2930061 |
|
cli_serve_logs |
|
airflow | {"host_name": "airflow-worker-4", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"} | ||
2930060 |
|
cli_serve_logs |
|
airflow | {"host_name": "airflow-worker-3", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"} | ||
2930059 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-05 23:00:00+00:00')] | |
2930058 |
|
cli_worker |
|
airflow | {"host_name": "airflow-worker-3", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"} | ||
2930057 |
|
cli_worker |
|
airflow | {"host_name": "airflow-worker-4", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"} | ||
2930056 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-27T07:00:00+00:00')] | |
2930055 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-14T05:00:00+00:00')] | |
2930054 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-15T16:00:00+00:00')] | |
2930053 |
|
cli_serve_logs |
|
airflow | {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"} | ||
2930052 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-13 18:00:00+00:00')] | |
2930051 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930050 |
|
booking-processing-job_v002 | check_cluster_status | running |
|
data.engineers@viooh.com | |
2930049 |
|
booking-processing-job_v002 | check_cluster_status | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'check_cluster_status', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930048 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | success |
|
data.engineers@viooh.com | |
2930047 |
|
cli_worker |
|
airflow | {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"} | ||
2930046 |
|
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-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2930045 |
|
livepop-shuffle-aggregator-modeltransform_v004 | create_emr_steps | running |
|
data.engineers@viooh.com | |
2930044 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
2930043 |
|
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-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2930042 |
|
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-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2930041 |
|
exchange-trade-summary_v1_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
2930040 |
|
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-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2930039 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | success |
|
data.engineers@viooh.com | |
2930038 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-13 17:00:00+00:00')] | |
2930037 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930036 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-12 17:00:00+00:00')] | |
2930035 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | running |
|
data.engineers@viooh.com | |
2930034 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | success |
|
data.engineers@viooh.com | |
2930033 |
|
exchange-trade-summary_v1_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
2930032 |
|
booking-processing-job_v002 | create_cluster_and_add_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_cluster_and_add_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930031 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2930030 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | running |
|
data.engineers@viooh.com | |
2930029 |
|
livepop-shuffle-aggregator-modeltransform_v004 | check_input_available | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"} |
2930028 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-25T21:00:00+00:00')] | |
2930027 |
|
publisher-s3-sync | publisher_sync_task | success |
|
data.engineers@viooh.com | |
2930026 |
|
publisher-s3-sync | publisher_sync_task | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"} |
2930025 |
|
publisher-s3-sync | publisher_sync_task | running |
|
data.engineers@viooh.com | |
2930024 |
|
exchange-trade-summary_v1_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2930023 |
|
exchange-trade-summary_v1_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
2930022 |
|
publisher-s3-sync | publisher_sync_task | cli_run |
|
airflow | {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"} |
2930021 |
|
exchange-trade-summary_v1_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"} |
2930020 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-06T05:00:00+00:00')] | |
2930019 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-12 03:00:00+00:00')] | |
2930018 |
|
booking-processing-job_v002 | create_emr_steps | success |
|
data.engineers@viooh.com | |
2930017 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-09-21T06:00:00+00:00')] | |
2930016 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930015 |
|
booking-processing-job_v002 | create_emr_steps | running |
|
data.engineers@viooh.com | |
2930014 |
|
booking-processing-job_v002 | create_emr_steps | cli_run |
|
airflow | {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'booking-processing-job_v002', 'create_emr_steps', '2024-11-22T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/booking-processing-job_v002.py']"} |
2930013 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('run_id', 'trig__2022-12-16T22:00:00+00:00'), ('execution_date', '2022-12-16 22:00:00+00:00')] | |
2930012 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-14 23:00:00+00:00')] | |
2930011 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-11 11:00:00+00:00')] | |
2930010 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-11 14:00:00+00:00')] | |
2930008 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-03 23:00:00+00:00')] | |
2930009 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-05 05:00:00+00:00')] | |
2930007 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-04 18:00:00+00:00')] | |
2930006 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-09-21T11:00:00+00:00')] | |
2930005 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-09-22T04:00:00+00:00')] | |
2930004 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-09T01:00:00+00:00')] | |
2930003 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-04 23:00:00+00:00')] | |
2930002 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-14 04:00:00+00:00')] | |
2930001 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-05 01:00:00+00:00')] | |
2930000 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-06T22:00:00+00:00')] | |
2929999 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-02 22:00:00+00:00')] | |
2929998 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-07T06:00:00+00:00')] | |
2929997 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-26 20:00:00+00:00')] | |
2929996 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-28 16:00:00+00:00')] | |
2929995 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-03 07:00:00+00:00')] | |
2929994 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-25T06:00:00+00:00')] | |
2929993 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-26T16:00:00+00:00')] | |
2929992 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-15 06:00:00+00:00')] | |
2929991 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-27 02:00:00+00:00')] | |
2929990 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-17T02:00:00+00:00')] | |
2929989 |
|
cli_scheduler |
|
airflow | {"host_name": "airflow-scheduler-676bff66f6-gfj2j", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"} | ||
2929988 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-03 14:00:00+00:00')] | |
2929987 |
|
cli_pool |
|
airflow | {"host_name": "airflow-scheduler-676bff66f6-gfj2j", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"} | ||
2929986 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-27T23:00:00+00:00')] | |
2929985 |
|
cli_variables |
|
airflow | {"host_name": "airflow-scheduler-676bff66f6-gfj2j", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"} | ||
2929984 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-18T21:00:00+00:00')] | |
2929983 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-15T18:00:00+00:00')] | |
2929982 |
|
cli_upgradedb |
|
airflow | {"host_name": "airflow-scheduler-676bff66f6-gfj2j", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"} | ||
2929981 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-28 19:00:00+00:00')] | |
2929980 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-14 09:00:00+00:00')] | |
2929979 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-27T08:00:00+00:00')] | |
2929978 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-14 14:00:00+00:00')] | |
2929977 |
|
booking-processing-job_v002 | check_cluster_status | task |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-05-02T11:00:00+00:00')] |
2929976 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-26T07:00:00+00:00')] | |
2929975 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-28 23:00:00+00:00')] | |
2929974 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-05 06:00:00+00:00')] | |
2929973 |
|
livepop-shuffle-aggregator-modeltransform_v004 | graph |
|
anonymous | [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-11-22 04:00:00+00:00')] | |
2929972 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-05T22:00:00+00:00')] | |
2929971 |
|
publisher-s3-sync | graph |
|
anonymous | [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-04-06 07:00:00+00:00')] | |
2929970 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('execution_date', '2023-05-07T10:00:00+00:00')] | |
2929969 |
|
booking-processing-job_v002 | graph |
|
anonymous | [('dag_id', 'booking-processing-job_v002'), ('run_id', 'trig__2023-02-12T23:00:00+00:00'), ('execution_date', '2023-02-12 23:00:00+00:00')] | |
2929968 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-25 13:00:00+00:00')] | |
2929967 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-25T13:00:00+00:00')] | |
2929966 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-25 16:00:00+00:00')] | |
2929965 |
|
campaign-history-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-history-job_v002'), ('execution_date', '2021-05-29 07:00:00+00:00')] | |
2929964 |
|
campaign-flow-job_v002 | graph |
|
anonymous | [('dag_id', 'campaign-flow-job_v002'), ('execution_date', '2023-03-25T01:00:00+00:00')] |