Logs

Id Dttm Dag Id Task Id Event Execution Date Owner Extra
2240888 07-02T12:00:05.263784+00:00 publisher-s3-sync publisher_sync_task cli_run 07-02T11:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-07-02T11:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
2240887 07-02T11:55:05.663564+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240886 07-02T11:55:04.292470+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240885 07-02T11:55:03.068270+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240884 07-02T11:55:01.583157+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240883 07-02T11:50:19.444287+00:00 pop-quality-check_v002 check_cluster_status task 2022-09-02T01:30:00+00:00 anonymous [('dag_id', 'pop-quality-check_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2022-09-02T01:30:00+00:00')]
2240882 07-02T11:45:35.892163+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240881 07-02T11:45:34.506868+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240880 07-02T11:45:33.200416+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240879 07-02T11:45:31.661526+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240878 07-02T11:43:29.873582+00:00 booking-processing-job_v002 check_cluster_status task 2020-11-03T18:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2020-11-03T18:00:00+00:00')]
2240877 07-02T11:43:27.607419+00:00 exchange-trade-summary_v1_v002 check_cluster_status task 02-28T09:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2024-02-28T09:00:00+00:00')]
2240876 07-02T11:37:05.784946+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240875 07-02T11:37:04.388237+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240874 07-02T11:37:03.153077+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240873 07-02T11:37:01.662558+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240872 07-02T11:31:51.548874+00:00 campaign-versioning-job_v002 graph 2020-10-26T09:28:31.689257+00:00 anonymous [('dag_id', 'campaign-versioning-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2020-10-26T09:28:31.689257+00:00')]
2240871 07-02T11:27:35.896334+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240870 07-02T11:27:34.383520+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240869 07-02T11:27:33.117346+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240868 07-02T11:27:31.660901+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240867 07-02T11:26:18.205929+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 05-10T15:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('run_id', 'scheduled__2024-05-10T15:00:00+00:00'), ('execution_date', '2024-05-10 15:00:00+00:00')]
2240866 07-02T11:24:56.943142+00:00 booking-processing-job_v002 graph 2020-11-03T15:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_cluster_and_add_emr_steps'), ('execution_date', '2020-11-03T15:00:00+00:00')]
2240865 07-02T11:24:41.108877+00:00 publisher-s3-sync graph 05-07T05:00:00+00:00 anonymous [('dag_id', 'publisher-s3-sync'), ('execution_date', '2024-05-07 05:00:00+00:00')]
2240864 07-02T11:24:10.682222+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps task 2021-02-11T17:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2021-02-11T17:05:00+00:00')]
2240863 07-02T11:23:06.368377+00:00 exchange-trade-summary_v1_v002 check_cluster_status success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240862 07-02T11:20:05.879159+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240861 07-02T11:20:04.581221+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240860 07-02T11:20:03.306025+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240859 07-02T11:20:01.755810+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240858 07-02T11:17:49.813079+00:00 vc-asset-import_v002 check_cluster_status task 2021-02-11T13:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'check_cluster_status'), ('execution_date', '2021-02-11T13:05:00+00:00')]
2240857 07-02T11:15:52.517774+00:00 vc-asset-import_v002 check_cluster_status success 07-02T10:05:00+00:00 data.engineers@viooh.com
2240856 07-02T11:15:29.657076+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240855 07-02T11:07:35.715835+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240854 07-02T11:07:34.400794+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240853 07-02T11:07:33.125109+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240852 07-02T11:07:31.662282+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240851 07-02T11:05:50.730081+00:00 vc-asset-import_v002 check_cluster_status cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'check_cluster_status', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240850 07-02T11:05:50.695159+00:00 vc-asset-import_v002 check_cluster_status running 07-02T10:05:00+00:00 data.engineers@viooh.com
2240849 07-02T11:05:50.044082+00:00 vc-asset-import_v002 check_cluster_status cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'check_cluster_status', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240848 07-02T11:05:28.929265+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps success 07-02T10:05:00+00:00 data.engineers@viooh.com
2240847 07-02T11:05:28.118935+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240846 07-02T11:05:28.092085+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps running 07-02T10:05:00+00:00 data.engineers@viooh.com
2240845 07-02T11:05:27.540348+00:00 vc-asset-import_v002 create_cluster_and_add_emr_steps cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240844 07-02T11:05:07.679651+00:00 vc-asset-import_v002 create_emr_steps success 07-02T10:05:00+00:00 data.engineers@viooh.com
2240843 07-02T11:05:06.540146+00:00 vc-asset-import_v002 create_emr_steps cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_emr_steps', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240842 07-02T11:05:06.508971+00:00 vc-asset-import_v002 create_emr_steps running 07-02T10:05:00+00:00 data.engineers@viooh.com
2240841 07-02T11:05:05.890538+00:00 vc-asset-import_v002 create_emr_steps cli_run 07-02T10:05:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'vc-asset-import_v002', 'create_emr_steps', '2024-07-02T10:05:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/vc-asset-import_v002.py']"}
2240840 07-02T11:01:26.826087+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240839 07-02T11:01:26.790672+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240838 07-02T11:01:26.172226+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_cluster_status cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_cluster_status', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240837 07-02T11:01:09.906618+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps xcom 03-25T15:00:00+00:00 anonymous [('dag_id', 'exchange-trade-summary_v1_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2024-03-25T15:00:00+00:00')]
2240836 07-02T11:01:05.338219+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240835 07-02T11:01:04.292565+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 07-02T10:00:00+00:00 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-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240834 07-02T11:01:04.259736+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240833 07-02T11:01:03.615351+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_cluster_and_add_emr_steps cli_run 07-02T10:00:00+00:00 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-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240832 07-02T11:01:02.733319+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240831 07-02T11:01:02.677101+00:00 exchange-trade-summary_v1_v002 check_cluster_status running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240830 07-02T11:01:01.991168+00:00 exchange-trade-summary_v1_v002 check_cluster_status cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'check_cluster_status', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240829 07-02T11:00:57.003753+00:00 cli_serve_logs airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'serve_logs']"}
2240828 07-02T11:00:53.793004+00:00 cli_worker airflow {"host_name": "airflow-worker-2", "full_command": "['/home/airflow/.local/bin/airflow', 'worker']"}
2240827 07-02T11:00:46.169045+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240826 07-02T11:00:44.595619+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240825 07-02T11:00:44.550025+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240824 07-02T11:00:44.051858+00:00 booking-processing-job_v002 graph 2020-11-04T06:00:00+00:00 anonymous [('dag_id', 'booking-processing-job_v002'), ('root', 'create_emr_steps'), ('execution_date', '2020-11-04T06:00:00+00:00')]
2240823 07-02T11:00:43.879731+00:00 livepop-shuffle-aggregator-modeltransform_v004 create_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'create_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240822 07-02T11:00:41.503963+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240821 07-02T11:00:40.652373+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240820 07-02T11:00:40.606586+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240819 07-02T11:00:39.854440+00:00 exchange-trade-summary_v1_v002 create_cluster_and_add_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_cluster_and_add_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240818 07-02T11:00:24.072388+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240817 07-02T11:00:23.402357+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240816 07-02T11:00:23.356648+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240815 07-02T11:00:23.207615+00:00 exchange-trade-summary_v1_v002 create_emr_steps success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240814 07-02T11:00:22.731927+00:00 livepop-shuffle-aggregator-modeltransform_v004 check_input_available cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'livepop-shuffle-aggregator-modeltransform_v004', 'check_input_available', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/campaign-compliance/livepop-shuffle-aggregator-modeltransform_v004.py']"}
2240813 07-02T11:00:22.669499+00:00 publisher-s3-sync publisher_sync_task success 07-02T10:00:00+00:00 data.engineers@viooh.com
2240812 07-02T11:00:21.241694+00:00 publisher-s3-sync publisher_sync_task cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
2240811 07-02T11:00:21.172819+00:00 publisher-s3-sync publisher_sync_task running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240810 07-02T11:00:21.154853+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240809 07-02T11:00:21.110337+00:00 exchange-trade-summary_v1_v002 create_emr_steps running 07-02T10:00:00+00:00 data.engineers@viooh.com
2240808 07-02T11:00:20.295083+00:00 exchange-trade-summary_v1_v002 create_emr_steps cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'exchange-trade-summary_v1_v002', 'create_emr_steps', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/exchange-reporting/exchange-trade-summary_v1_v002.py']"}
2240807 07-02T11:00:19.822084+00:00 publisher-s3-sync publisher_sync_task cli_run 07-02T10:00:00+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/home/airflow/.local/bin/airflow', 'run', 'publisher-s3-sync', 'publisher_sync_task', '2024-07-02T10:00:00+00:00', '--local', '--pool', 'default_pool', '-sd', '/opt/airflow/dags/cn/publisher_service/publisher_service_sync.py']"}
2240806 07-02T11:00:06.077383+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240805 07-02T11:00:04.717632+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240804 07-02T11:00:03.288109+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240803 07-02T11:00:01.729569+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240802 07-02T10:58:45.706829+00:00 pop-quality-check_v002 tree anonymous [('dag_id', 'pop-quality-check_v002')]
2240801 07-02T10:58:16.084108+00:00 booking-processing-job_v002 tree anonymous [('dag_id', 'booking-processing-job_v002')]
2240800 07-02T10:55:53.073081+00:00 vc-asset-import_v002 create_emr_steps task 06-01T15:05:00+00:00 anonymous [('dag_id', 'vc-asset-import_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2024-06-01T15:05:00+00:00')]
2240799 07-02T10:52:35.781764+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240798 07-02T10:52:34.496015+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240797 07-02T10:52:33.192252+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240796 07-02T10:52:31.662982+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240795 07-02T10:50:40.616570+00:00 Terminate_Custom_EMR_Clusters graph 06-07T18:30:00+00:00 anonymous [('dag_id', 'Terminate_Custom_EMR_Clusters'), ('execution_date', '2024-06-07 18:30:00+00:00')]
2240794 07-02T10:42:05.676519+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}
2240793 07-02T10:42:04.409116+00:00 cli_pool airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'pool', '-i', '/home/airflow/variables-pools/pools.json']"}
2240792 07-02T10:42:03.060998+00:00 cli_variables airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'variables', '-i', '/home/airflow/variables-pools/variables.json']"}
2240791 07-02T10:42:01.563737+00:00 cli_upgradedb airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'upgradedb']"}
2240790 07-02T10:34:34.588093+00:00 livepop-shuffle-aggregator-modeltransform_v004 graph 05-07T13:00:00+00:00 anonymous [('dag_id', 'livepop-shuffle-aggregator-modeltransform_v004'), ('execution_date', '2024-05-07 13:00:00+00:00')]
2240789 07-02T10:33:35.982378+00:00 cli_scheduler airflow {"host_name": "airflow-scheduler-676bff66f6-25vgd", "full_command": "['/home/airflow/.local/bin/airflow', 'scheduler', '-n', '-1']"}