Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success booking-processing-job_v002 check_cluster_status 2021-05-01T09:00:00+00:00 EmrJobFlowSensor 2021-05-01T10:11:18.324219+00:00 2021-05-01T10:21:21.518577+00:00 0:10:03.194358 23253 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:11:16.036258+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T10:10:59.217358+00:00 2021-05-01T10:11:00.871805+00:00 0:00:01.654447 23252 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T10:10:56.062506+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T10:10:56.746762+00:00 2021-05-01T10:10:58.822217+00:00 0:00:02.075455 23251 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T10:10:54.084173+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T09:00:00+00:00 PythonOperator 2021-05-01T10:10:36.513590+00:00 2021-05-01T10:10:39.817012+00:00 0:00:03.303422 23250 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T10:10:33.943887+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T09:00:00+00:00 PythonOperator 2021-05-01T10:10:36.297745+00:00 2021-05-01T10:10:39.404668+00:00 0:00:03.106923 23249 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T10:10:33.943853+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T09:00:00+00:00 TriggerDagRunOperator 2021-05-01T10:10:12.300235+00:00 2021-05-01T10:10:12.868443+00:00 0:00:00.568208 23248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:10:09.922932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T09:00:00+00:00 TriggerDagRunOperator 2021-05-01T10:10:12.262821+00:00 2021-05-01T10:10:12.709620+00:00 0:00:00.446799 23247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:10:09.922968+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T09:05:00+00:00 EmrJobFlowSensor 2021-05-01T10:05:57.925790+00:00 2021-05-01T10:15:00.455582+00:00 0:09:02.529792 23246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T10:05:55.661114+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T10:05:38.046104+00:00 2021-05-01T10:05:39.698118+00:00 0:00:01.652014 23245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T10:05:35.656493+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T09:05:00+00:00 PythonOperator 2021-05-01T10:05:15.791261+00:00 2021-05-01T10:05:18.824520+00:00 0:00:03.033259 23244 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T10:05:13.561265+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T09:00:00+00:00 EmrJobFlowSensor 2021-05-01T10:00:47.752567+00:00 2021-05-01T10:09:50.384631+00:00 0:09:02.632064 23243 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T10:00:45.261077+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T10:00:27.574871+00:00 2021-05-01T10:00:29.393322+00:00 0:00:01.818451 23242 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T10:00:25.143795+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T09:00:00+00:00 PythonOperator 2021-05-01T10:00:05.903326+00:00 2021-05-01T10:00:08.998633+00:00 0:00:03.095307 23241 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T10:00:03.120735+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T08:00:00+00:00 EmrJobFlowSensor 2021-05-01T09:11:26.436337+00:00 2021-05-01T09:21:29.134545+00:00 0:10:02.698208 23239 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:11:23.632100+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T08:00:00+00:00 EmrJobFlowSensor 2021-05-01T09:11:24.103818+00:00 2021-05-01T09:21:27.308526+00:00 0:10:03.204708 23238 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:11:21.615438+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T09:11:04.831668+00:00 2021-05-01T09:11:06.589594+00:00 0:00:01.757926 23237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T09:11:01.673103+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T09:11:02.152938+00:00 2021-05-01T09:11:04.239136+00:00 0:00:02.086198 23236 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T09:10:59.741008+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T08:00:00+00:00 PythonOperator 2021-05-01T09:10:42.008788+00:00 2021-05-01T09:10:45.315411+00:00 0:00:03.306623 23235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T09:10:39.642356+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T08:00:00+00:00 PythonOperator 2021-05-01T09:10:40.299619+00:00 2021-05-01T09:10:43.316401+00:00 0:00:03.016782 23234 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T09:10:37.645660+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T08:00:00+00:00 TriggerDagRunOperator 2021-05-01T09:10:30.306709+00:00 2021-05-01T09:10:30.765092+00:00 0:00:00.458383 23233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:10:27.662813+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T08:00:00+00:00 TriggerDagRunOperator 2021-05-01T09:10:30.205268+00:00 2021-05-01T09:10:30.803657+00:00 0:00:00.598389 23232 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:10:27.662858+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T08:05:00+00:00 EmrJobFlowSensor 2021-05-01T09:06:03.290419+00:00 2021-05-01T09:14:05.870532+00:00 0:08:02.580113 23231 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T09:06:01.126450+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T09:05:35.556942+00:00 2021-05-01T09:05:37.199746+00:00 0:00:01.642804 23230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T09:05:33.163316+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T08:05:00+00:00 PythonOperator 2021-05-01T09:05:13.224151+00:00 2021-05-01T09:05:16.215404+00:00 0:00:02.991253 23229 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T09:05:11.005374+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T08:00:00+00:00 EmrJobFlowSensor 2021-05-01T09:01:04.913245+00:00 2021-05-01T09:10:07.727010+00:00 0:09:02.813765 23228 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T09:01:02.489833+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T09:00:38.774662+00:00 2021-05-01T09:00:40.517509+00:00 0:00:01.742847 23227 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T09:00:36.421025+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T08:00:00+00:00 PythonOperator 2021-05-01T09:00:17.135343+00:00 2021-05-01T09:00:20.165138+00:00 0:00:03.029795 23226 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T09:00:14.403824+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T07:00:00+00:00 EmrJobFlowSensor 2021-05-01T08:12:17.934217+00:00 2021-05-01T08:22:20.589824+00:00 0:10:02.655607 23224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:12:15.644230+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T07:00:00+00:00 EmrJobFlowSensor 2021-05-01T08:12:06.256705+00:00 2021-05-01T08:22:09.216041+00:00 0:10:02.959336 23223 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:12:03.587112+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T08:11:57.961876+00:00 2021-05-01T08:11:59.742589+00:00 0:00:01.780713 23222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T08:11:55.575575+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T08:11:43.702085+00:00 2021-05-01T08:11:45.482815+00:00 0:00:01.780730 23221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T08:11:41.523674+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T07:00:00+00:00 PythonOperator 2021-05-01T08:11:35.900122+00:00 2021-05-01T08:11:38.990009+00:00 0:00:03.089887 23220 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T08:11:33.520524+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T07:00:00+00:00 PythonOperator 2021-05-01T08:11:21.975490+00:00 2021-05-01T08:11:25.329931+00:00 0:00:03.354441 23219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T08:11:19.564812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T07:00:00+00:00 TriggerDagRunOperator 2021-05-01T08:11:16.139584+00:00 2021-05-01T08:11:16.568036+00:00 0:00:00.428452 23218 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:11:13.571127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T07:00:00+00:00 TriggerDagRunOperator 2021-05-01T08:11:16.118563+00:00 2021-05-01T08:11:16.681737+00:00 0:00:00.563174 23217 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:11:13.571081+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T07:05:00+00:00 EmrJobFlowSensor 2021-05-01T08:05:55.169001+00:00 2021-05-01T08:13:57.616187+00:00 0:08:02.447186 23216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T08:05:53.002196+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T08:05:33.353778+00:00 2021-05-01T08:05:35.061474+00:00 0:00:01.707696 23215 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T08:05:30.987032+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T07:05:00+00:00 PythonOperator 2021-05-01T08:05:11.352996+00:00 2021-05-01T08:05:14.432136+00:00 0:00:03.079140 23214 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T08:05:08.965317+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T07:00:00+00:00 EmrJobFlowSensor 2021-05-01T08:00:54.852562+00:00 2021-05-01T08:10:57.679307+00:00 0:10:02.826745 23213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T08:00:52.493675+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T08:00:32.625056+00:00 2021-05-01T08:00:34.364927+00:00 0:00:01.739871 23212 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T08:00:30.467082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T07:00:00+00:00 PythonOperator 2021-05-01T08:00:12.746087+00:00 2021-05-01T08:00:15.807552+00:00 0:00:03.061465 23211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T08:00:10.449321+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T06:00:00+00:00 EmrJobFlowSensor 2021-05-01T07:11:00.529159+00:00 2021-05-01T07:20:03.218446+00:00 0:09:02.689287 23209 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:58.275519+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T06:00:00+00:00 EmrJobFlowSensor 2021-05-01T07:10:52.513607+00:00 2021-05-01T07:20:55.470040+00:00 0:10:02.956433 23208 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:50.238008+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T07:10:38.485890+00:00 2021-05-01T07:10:40.157567+00:00 0:00:01.671677 23207 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T07:10:36.224623+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T07:10:30.520874+00:00 2021-05-01T07:10:32.354178+00:00 0:00:01.833304 23206 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T07:10:28.240647+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T06:00:00+00:00 PythonOperator 2021-05-01T07:10:18.483515+00:00 2021-05-01T07:10:21.564128+00:00 0:00:03.080613 23205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T07:10:16.211150+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T06:00:00+00:00 PythonOperator 2021-05-01T07:10:10.579485+00:00 2021-05-01T07:10:13.947285+00:00 0:00:03.367800 23204 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T07:10:08.204718+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T06:00:00+00:00 TriggerDagRunOperator 2021-05-01T07:10:04.996097+00:00 2021-05-01T07:10:05.631537+00:00 0:00:00.635440 23203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:02.268640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T06:00:00+00:00 TriggerDagRunOperator 2021-05-01T07:10:04.890088+00:00 2021-05-01T07:10:05.450724+00:00 0:00:00.560636 23202 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:10:02.268590+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T06:05:00+00:00 EmrJobFlowSensor 2021-05-01T07:06:04.400661+00:00 2021-05-01T07:15:07.182242+00:00 0:09:02.781581 23201 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T07:06:01.904052+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T07:05:42.121870+00:00 2021-05-01T07:05:43.777512+00:00 0:00:01.655642 23200 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T07:05:39.948733+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T06:05:00+00:00 PythonOperator 2021-05-01T07:05:20.189774+00:00 2021-05-01T07:05:23.197684+00:00 0:00:03.007910 23199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T07:05:17.784740+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T06:00:00+00:00 EmrJobFlowSensor 2021-05-01T07:00:51.397592+00:00 2021-05-01T07:09:53.996733+00:00 0:09:02.599141 23198 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T07:00:49.198857+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T07:00:31.647007+00:00 2021-05-01T07:00:33.363461+00:00 0:00:01.716454 23197 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T07:00:29.259288+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T06:00:00+00:00 PythonOperator 2021-05-01T07:00:09.635911+00:00 2021-05-01T07:00:12.753292+00:00 0:00:03.117381 23196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T07:00:07.165280+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T05:00:00+00:00 EmrJobFlowSensor 2021-05-01T06:17:35.286991+00:00 2021-05-01T06:25:37.915242+00:00 0:08:02.628251 23195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:17:33.009690+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T05:00:00+00:00 EmrJobFlowSensor 2021-05-01T06:17:27.283522+00:00 2021-05-01T06:27:30.189518+00:00 0:10:02.905996 23194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:17:25.001693+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T06:17:11.450053+00:00 2021-05-01T06:17:13.352358+00:00 0:00:01.902305 23193 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T06:17:09.046944+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T06:17:05.470430+00:00 2021-05-01T06:17:07.333244+00:00 0:00:01.862814 23192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T06:17:02.983217+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T05:00:00+00:00 PythonOperator 2021-05-01T06:16:51.108411+00:00 2021-05-01T06:16:54.132163+00:00 0:00:03.023752 23191 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T06:16:48.919047+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T05:00:00+00:00 PythonOperator 2021-05-01T06:16:43.090653+00:00 2021-05-01T06:16:46.387884+00:00 0:00:03.297231 23190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T06:16:40.912142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T05:00:00+00:00 TriggerDagRunOperator 2021-05-01T06:16:31.426971+00:00 2021-05-01T06:16:31.849781+00:00 0:00:00.422810 23189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:16:28.274725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T05:00:00+00:00 TriggerDagRunOperator 2021-05-01T06:16:31.400414+00:00 2021-05-01T06:16:31.968917+00:00 0:00:00.568503 23188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:16:28.274782+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T05:05:00+00:00 EmrJobFlowSensor 2021-05-01T06:05:49.179658+00:00 2021-05-01T06:14:51.756895+00:00 0:09:02.577237 23186 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T06:05:46.929282+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T06:05:29.184633+00:00 2021-05-01T06:05:30.820492+00:00 0:00:01.635859 23185 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T06:05:26.911459+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T05:05:00+00:00 PythonOperator 2021-05-01T06:05:07.258731+00:00 2021-05-01T06:05:10.263309+00:00 0:00:03.004578 23184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T06:05:04.966702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T05:00:00+00:00 EmrJobFlowSensor 2021-05-01T06:01:04.879032+00:00 2021-05-01T06:11:07.808321+00:00 0:10:02.929289 23183 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T06:01:02.483518+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T06:00:42.815580+00:00 2021-05-01T06:00:44.503486+00:00 0:00:01.687906 23182 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T06:00:40.479582+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T05:00:00+00:00 PythonOperator 2021-05-01T06:00:20.842263+00:00 2021-05-01T06:00:24.164434+00:00 0:00:03.322171 23181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T06:00:18.443622+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T04:00:00+00:00 EmrJobFlowSensor 2021-05-01T05:11:49.791801+00:00 2021-05-01T05:20:52.508882+00:00 0:09:02.717081 23180 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:11:47.401352+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T04:00:00+00:00 EmrJobFlowSensor 2021-05-01T05:11:37.521368+00:00 2021-05-01T05:21:40.319631+00:00 0:10:02.798263 23179 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:11:35.351014+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T05:11:27.478424+00:00 2021-05-01T05:11:29.160645+00:00 0:00:01.682221 23178 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T05:11:25.290402+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T05:11:15.486826+00:00 2021-05-01T05:11:17.204741+00:00 0:00:01.717915 23177 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T05:11:13.282315+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T04:00:00+00:00 PythonOperator 2021-05-01T05:11:07.564602+00:00 2021-05-01T05:11:10.549645+00:00 0:00:02.985043 23176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T05:11:05.276590+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T04:00:00+00:00 PythonOperator 2021-05-01T05:10:54.040819+00:00 2021-05-01T05:10:57.360746+00:00 0:00:03.319927 23175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T05:10:51.210931+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T04:05:00+00:00 EmrJobFlowSensor 2021-05-01T05:10:48.606252+00:00 2021-05-01T05:14:50.603401+00:00 0:04:01.997149 23174 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:10:45.207009+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T04:00:00+00:00 TriggerDagRunOperator 2021-05-01T05:10:46.798643+00:00 2021-05-01T05:10:47.558893+00:00 0:00:00.760250 23173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:10:43.166001+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T04:00:00+00:00 TriggerDagRunOperator 2021-05-01T05:10:45.910861+00:00 2021-05-01T05:10:46.439814+00:00 0:00:00.528953 23172 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T05:10:43.165975+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T05:05:32.846635+00:00 2021-05-01T05:05:34.463397+00:00 0:00:01.616762 23170 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T05:05:30.684785+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T04:05:00+00:00 PythonOperator 2021-05-01T05:05:10.810914+00:00 2021-05-01T05:05:13.857041+00:00 0:00:03.046127 23169 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T05:05:08.591958+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T04:00:00+00:00 EmrJobFlowSensor 2021-05-01T05:00:56.302292+00:00 2021-05-01T05:09:58.943719+00:00 0:09:02.641427 23168 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T05:00:54.154645+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T05:00:36.315201+00:00 2021-05-01T05:00:38.093704+00:00 0:00:01.778503 23167 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T05:00:34.138202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T04:00:00+00:00 PythonOperator 2021-05-01T05:00:12.357246+00:00 2021-05-01T05:00:15.434444+00:00 0:00:03.077198 23166 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T05:00:10.115465+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T03:00:00+00:00 EmrJobFlowSensor 2021-05-01T04:10:25.427788+00:00 2021-05-01T04:19:28.010785+00:00 0:09:02.582997 23165 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:10:23.214574+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T03:00:00+00:00 EmrJobFlowSensor 2021-05-01T04:10:19.833779+00:00 2021-05-01T04:19:22.679413+00:00 0:09:02.845634 23164 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:10:17.288722+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T04:10:03.653668+00:00 2021-05-01T04:10:05.436440+00:00 0:00:01.782772 23163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T04:10:01.246360+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T04:09:57.316634+00:00 2021-05-01T04:09:59.168754+00:00 0:00:01.852120 23162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T04:09:55.094215+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-01T03:00:00+00:00 PythonOperator 2021-05-01T04:09:43.388675+00:00 2021-05-01T04:09:46.483442+00:00 0:00:03.094767 23161 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T04:09:41.040204+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-01T03:00:00+00:00 PythonOperator 2021-05-01T04:09:37.296628+00:00 2021-05-01T04:09:40.580835+00:00 0:00:03.284207 23160 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T04:09:35.047986+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-01T03:00:00+00:00 TriggerDagRunOperator 2021-05-01T04:09:27.371233+00:00 2021-05-01T04:09:27.957012+00:00 0:00:00.585779 23159 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:09:25.029201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-01T03:00:00+00:00 TriggerDagRunOperator 2021-05-01T04:09:27.342644+00:00 2021-05-01T04:09:27.774218+00:00 0:00:00.431574 23158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:09:25.029233+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-01T03:05:00+00:00 EmrJobFlowSensor 2021-05-01T04:06:35.138715+00:00 2021-05-01T04:15:37.929801+00:00 0:09:02.791086 23157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T04:06:32.828528+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-01T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-01T04:06:07.022113+00:00 2021-05-01T04:06:08.720028+00:00 0:00:01.697915 23156 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T04:06:04.803948+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-01T03:05:00+00:00 PythonOperator 2021-05-01T04:05:47.155776+00:00 2021-05-01T04:05:50.111648+00:00 0:00:02.955872 23155 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T04:05:44.785537+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-01T03:00:00+00:00 EmrJobFlowSensor 2021-05-01T04:01:06.563440+00:00 2021-05-01T04:09:09.294253+00:00 0:08:02.730813 23153 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-01T04:01:04.287102+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-01T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T04:00:44.522540+00:00 2021-05-01T04:00:46.334785+00:00 0:00:01.812245 23152 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-01T04:00:42.206393+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-01T03:00:00+00:00 PythonOperator 2021-05-01T04:00:24.435858+00:00 2021-05-01T04:00:27.478239+00:00 0:00:03.042381 23151 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-01T04:00:22.185573+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-01T02:00:00+00:00 EmrJobFlowSensor 2021-05-01T03:15:27.338444+00:00 2021-05-01T03:25:30.188160+00:00 0:10:02.849716 23150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:15:24.988174+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-01T02:00:00+00:00 EmrJobFlowSensor 2021-05-01T03:15:25.303558+00:00 2021-05-01T03:24:28.040595+00:00 0:09:02.737037 23149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-01T03:15:22.981079+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-01T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-01T03:15:07.216934+00:00 2021-05-01T03:15:09.031135+00:00 0:00:01.814201 23148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-01T03:15:04.942161+00:00 2 default_pool