Logs


Id Dttm Dag Id Task Id Event Execution Date Owner Extra
7223 2020-10-27T07:15:09.901366+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7222 2020-10-27T07:15:09.842586+00:00 campaign-delta-job_v002 check_cluster_status running 2020-10-27T07:14:42.288860+00:00 data.engineers@viooh.com
7221 2020-10-27T07:15:09.284199+00:00 campaign-delta-job_v002 check_cluster_status cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'check_cluster_status', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7220 2020-10-27T07:15:00.974901+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps success 2020-10-27T07:14:42.288860+00:00 data.engineers@viooh.com
7219 2020-10-27T07:14:59.388674+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7218 2020-10-27T07:14:59.343524+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps running 2020-10-27T07:14:42.288860+00:00 data.engineers@viooh.com
7217 2020-10-27T07:14:58.852819+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-1", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_cluster_and_add_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7216 2020-10-27T07:14:52.418394+00:00 campaign-delta-job_v002 create_emr_steps success 2020-10-27T07:14:42.288860+00:00 data.engineers@viooh.com
7215 2020-10-27T07:14:49.696056+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7214 2020-10-27T07:14:49.639458+00:00 campaign-delta-job_v002 create_emr_steps running 2020-10-27T07:14:42.288860+00:00 data.engineers@viooh.com
7213 2020-10-27T07:14:49.118844+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T07:14:42.288860+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T07:14:42.288860+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7212 2020-10-27T07:14:42.273608+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5fI3A.RQBHpJQEWQ9IhfKu2Kav_UcK8uk')]
7211 2020-10-27T07:14:36.503387+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7209 2020-10-27T06:25:06.376016+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')]
7208 2020-10-27T06:25:05.895683+00:00 campaign-delta-job_v002 create_emr_steps log 2020-10-27T05:28:31.182130+00:00 anonymous [('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('format', 'json')]
7207 2020-10-27T06:24:59.484989+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')]
7206 2020-10-27T06:15:19.776916+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7180 2020-10-27T06:08:36.837788+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')]
7177 2020-10-27T06:08:35.056589+00:00 campaign-delta-job_v002 create_emr_steps log 2020-10-27T05:28:31.182130+00:00 anonymous [('task_id', 'create_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('format', 'json')]
7174 2020-10-27T06:08:21.785082+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7173 2020-10-27T06:07:46.934420+00:00 campaign-delta-job_v002 graph anonymous [('dag_id', 'campaign-delta-job_v002'), ('execution_date', '')]
7172 2020-10-27T06:07:37.422976+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7171 2020-10-27T06:06:24.372768+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')]
7170 2020-10-27T06:06:15.947369+00:00 campaign-delta-job_v002 create_emr_steps log 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00')]
7169 2020-10-27T05:35:45.212594+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00'), ('try_number', '1'), ('metadata', 'null')]
7168 2020-10-27T05:35:44.260763+00:00 campaign-delta-job_v002 create_emr_steps log 2020-10-27T05:28:31.182130+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:28:31.182130+00:00')]
7167 2020-10-27T05:35:29.732014+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7166 2020-10-27T05:35:13.956567+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')]
7164 2020-10-27T05:28:44.920313+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:28:31.182130+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:28:31.182130+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7163 2020-10-27T05:28:44.876688+00:00 campaign-delta-job_v002 create_emr_steps running 2020-10-27T05:28:31.182130+00:00 data.engineers@viooh.com
7162 2020-10-27T05:28:44.453529+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:28:31.182130+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:28:31.182130+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7161 2020-10-27T05:28:31.171623+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5ev-g.cnJ8BJecQfBi3PxB1yn7x-KWJ28')]
7160 2020-10-27T05:28:26.845338+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002'), ('num_runs', ''), ('root', '')]
7159 2020-10-27T05:13:25.071700+00:00 campaign-delta-job_v002 create_emr_steps get_logs_with_metadata 2020-10-27T05:12:16.511905+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:12:16.511905+00:00'), ('try_number', '1'), ('metadata', 'null')]
7158 2020-10-27T05:13:23.441015+00:00 campaign-delta-job_v002 create_emr_steps log 2020-10-27T05:12:16.511905+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_emr_steps'), ('execution_date', '2020-10-27T05:12:16.511905+00:00')]
7157 2020-10-27T05:12:45.055468+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7156 2020-10-27T05:12:34.029555+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps log 2020-10-27T05:08:42.421887+00:00 anonymous [('dag_id', 'campaign-delta-job_v002'), ('task_id', 'create_cluster_and_add_emr_steps'), ('execution_date', '2020-10-27T05:08:42.421887+00:00')]
7155 2020-10-27T05:12:28.115881+00:00 campaign-delta-job_v002 create_cluster_and_add_emr_steps log 2020-10-27T05:08:42.421887+00:00 anonymous [('task_id', 'create_cluster_and_add_emr_steps'), ('dag_id', 'campaign-delta-job_v002'), ('execution_date', '2020-10-27T05:08:42.421887+00:00'), ('format', 'json')]
7154 2020-10-27T05:12:25.854517+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:12:16.511905+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:12:16.511905+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7153 2020-10-27T05:12:25.811861+00:00 campaign-delta-job_v002 create_emr_steps running 2020-10-27T05:12:16.511905+00:00 data.engineers@viooh.com
7152 2020-10-27T05:12:25.386265+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:12:16.511905+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:12:16.511905+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7151 2020-10-27T05:12:18.982022+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002'), ('num_runs', '')]
7150 2020-10-27T05:12:16.500353+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5esKw.YHJbaTCEZvXHzzQe6cQwnYQPGvQ')]
7149 2020-10-27T05:08:47.597939+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:08:42.421887+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:08:42.421887+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7148 2020-10-27T05:08:47.554053+00:00 campaign-delta-job_v002 create_emr_steps running 2020-10-27T05:08:42.421887+00:00 data.engineers@viooh.com
7147 2020-10-27T05:08:47.077416+00:00 campaign-delta-job_v002 create_emr_steps cli_run 2020-10-27T05:08:42.421887+00:00 airflow {"host_name": "airflow-worker-0", "full_command": "['/usr/local/bin/airflow', 'run', 'campaign-delta-job_v002', 'create_emr_steps', '2020-10-27T05:08:42.421887+00:00', '--local', '--pool', 'default_pool', '-sd', '/usr/local/airflow/dags/cn/campaign-compliance/campaign-delta-job_v002.py']"}
7146 2020-10-27T05:08:42.407403+00:00 campaign-delta-job_v002 trigger anonymous [('dag_id', 'campaign-delta-job_v002'), ('origin', '/admin/airflow/tree?dag_id=campaign-delta-job_v002'), ('csrf_token', 'ImM5MDI0N2Q3OWIzNGZiYjhjMDZmZDJjZTFhNGVjZTk1NGY5ZDJmYjEi.X5erUg.7RdK_UD19AJwG9Oskz7UKxsDRlw')]
7145 2020-10-27T05:08:38.142321+00:00 campaign-delta-job_v002 paused anonymous [('is_paused', 'true'), ('dag_id', 'campaign-delta-job_v002')]
7144 2020-10-27T05:08:35.954090+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7143 2020-10-27T05:08:34.795777+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]
7125 2020-10-27T04:25:18.768975+00:00 campaign-delta-job_v002 tree anonymous [('dag_id', 'campaign-delta-job_v002')]