Task Instances

Reset Filters
  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 campaign-flow-job_v002 check_cluster_status 2023-03-16T11:00:00+00:00 EmrJobFlowSensor 2023-03-16T12:14:00.358017+00:00 2023-03-16T12:14:00.914414+00:00 0:00:00.556397 354504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T12:13:57.722705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T12:00:46.233645+00:00 2023-03-16T12:00:47.060180+00:00 0:00:00.826535 354501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T12:00:44.007061+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T11:00:00+00:00 PythonOperator 2023-03-16T12:00:24.170492+00:00 2023-03-16T12:00:28.217843+00:00 0:00:04.047351 354499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T12:00:21.877439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T10:00:00+00:00 TriggerDagRunOperator 2023-03-16T11:21:40.112575+00:00 2023-03-16T11:21:40.605128+00:00 0:00:00.492553 354492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T11:21:37.240395+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T10:00:00+00:00 TriggerDagRunOperator 2023-03-16T11:21:39.937200+00:00 2023-03-16T11:21:40.399989+00:00 0:00:00.462789 354491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T11:21:37.240423+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T10:00:00+00:00 EmrJobFlowSensor 2023-03-16T11:02:11.658370+00:00 2023-03-16T11:12:13.429218+00:00 0:10:01.770848 354484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T11:02:09.462647+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T11:01:49.638439+00:00 2023-03-16T11:01:50.504141+00:00 0:00:00.865702 354482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T11:01:47.441590+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T10:00:00+00:00 PythonOperator 2023-03-16T11:01:28.180045+00:00 2023-03-16T11:01:31.543657+00:00 0:00:03.363612 354480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T11:01:25.438693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T09:00:00+00:00 TriggerDagRunOperator 2023-03-16T10:10:49.718920+00:00 2023-03-16T10:10:50.303098+00:00 0:00:00.584178 354470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T10:10:46.804567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T09:00:00+00:00 TriggerDagRunOperator 2023-03-16T10:10:49.618853+00:00 2023-03-16T10:10:50.094588+00:00 0:00:00.475735 354469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T10:10:46.804597+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T09:00:00+00:00 EmrJobFlowSensor 2023-03-16T10:00:53.590309+00:00 2023-03-16T10:09:55.297957+00:00 0:09:01.707648 354462 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T10:00:51.291297+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T10:00:31.564761+00:00 2023-03-16T10:00:32.745832+00:00 0:00:01.181071 354460 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T10:00:29.257894+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T09:00:00+00:00 PythonOperator 2023-03-16T10:00:09.446703+00:00 2023-03-16T10:00:13.411842+00:00 0:00:03.965139 354458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T10:00:07.243319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T08:00:00+00:00 TriggerDagRunOperator 2023-03-16T09:11:18.616397+00:00 2023-03-16T09:11:19.105993+00:00 0:00:00.489596 354447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T09:11:16.168008+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T08:00:00+00:00 TriggerDagRunOperator 2023-03-16T09:11:18.362259+00:00 2023-03-16T09:11:18.834111+00:00 0:00:00.471852 354446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T09:11:16.168040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T08:00:00+00:00 EmrJobFlowSensor 2023-03-16T09:01:05.120415+00:00 2023-03-16T09:11:06.864179+00:00 0:10:01.743764 354440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T09:01:02.745745+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T09:00:42.853962+00:00 2023-03-16T09:00:43.674988+00:00 0:00:00.821026 354438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T09:00:40.679474+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T08:00:00+00:00 PythonOperator 2023-03-16T09:00:21.030803+00:00 2023-03-16T09:00:25.003515+00:00 0:00:03.972712 354436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T09:00:18.665477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T07:00:00+00:00 TriggerDagRunOperator 2023-03-16T08:11:13.525037+00:00 2023-03-16T08:11:14.055814+00:00 0:00:00.530777 354426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T08:11:11.157021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T07:00:00+00:00 TriggerDagRunOperator 2023-03-16T08:11:13.424119+00:00 2023-03-16T08:11:13.907590+00:00 0:00:00.483471 354425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T08:11:11.157053+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T07:00:00+00:00 EmrJobFlowSensor 2023-03-16T08:07:57.481507+00:00 2023-03-16T08:10:58.333207+00:00 0:03:00.851700 354422 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T08:07:54.906495+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T08:00:44.287164+00:00 2023-03-16T08:00:45.301782+00:00 0:00:01.014618 354417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T08:00:41.863543+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T07:00:00+00:00 PythonOperator 2023-03-16T08:00:22.213490+00:00 2023-03-16T08:00:25.537147+00:00 0:00:03.323657 354415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T08:00:19.839809+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T06:00:00+00:00 TriggerDagRunOperator 2023-03-16T07:13:10.655678+00:00 2023-03-16T07:13:11.281922+00:00 0:00:00.626244 354403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T07:13:07.764111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T06:00:00+00:00 TriggerDagRunOperator 2023-03-16T07:13:10.427602+00:00 2023-03-16T07:13:10.917894+00:00 0:00:00.490292 354402 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T07:13:07.764140+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T06:00:00+00:00 EmrJobFlowSensor 2023-03-16T07:02:53.896259+00:00 2023-03-16T07:12:55.708566+00:00 0:10:01.812307 354396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T07:02:51.211494+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T07:02:31.430133+00:00 2023-03-16T07:02:32.227608+00:00 0:00:00.797475 354394 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T07:02:29.118096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T06:00:00+00:00 PythonOperator 2023-03-16T07:02:09.431546+00:00 2023-03-16T07:02:12.464861+00:00 0:00:03.033315 354392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T07:02:07.095866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T05:00:00+00:00 TriggerDagRunOperator 2023-03-16T06:11:15.770660+00:00 2023-03-16T06:11:16.254291+00:00 0:00:00.483631 354381 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T06:11:13.165487+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T05:00:00+00:00 TriggerDagRunOperator 2023-03-16T06:11:15.424812+00:00 2023-03-16T06:11:15.914416+00:00 0:00:00.489604 354380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T06:11:13.165520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T05:00:00+00:00 EmrJobFlowSensor 2023-03-16T06:01:05.400631+00:00 2023-03-16T06:11:07.326641+00:00 0:10:01.926010 354374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T06:01:03.172065+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T06:00:43.369158+00:00 2023-03-16T06:00:44.414757+00:00 0:00:01.045599 354372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T06:00:41.154477+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T05:00:00+00:00 PythonOperator 2023-03-16T06:00:21.349341+00:00 2023-03-16T06:00:25.358247+00:00 0:00:04.008906 354370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T06:00:19.134912+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T04:00:00+00:00 TriggerDagRunOperator 2023-03-16T05:11:26.448944+00:00 2023-03-16T05:11:27.102571+00:00 0:00:00.653627 354360 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T05:11:21.490251+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T04:00:00+00:00 TriggerDagRunOperator 2023-03-16T05:11:23.961522+00:00 2023-03-16T05:11:24.437296+00:00 0:00:00.475774 354358 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T05:11:21.490264+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T04:00:00+00:00 EmrJobFlowSensor 2023-03-16T05:01:00.475610+00:00 2023-03-16T05:11:02.501221+00:00 0:10:02.025611 354354 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T05:00:58.015843+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T05:00:39.824594+00:00 2023-03-16T05:00:41.111410+00:00 0:00:01.286816 354352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T05:00:35.964068+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T04:00:00+00:00 PythonOperator 2023-03-16T05:00:16.169753+00:00 2023-03-16T05:00:20.208752+00:00 0:00:04.038999 354350 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T05:00:13.956966+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T03:00:00+00:00 TriggerDagRunOperator 2023-03-16T04:17:58.435986+00:00 2023-03-16T04:17:58.948184+00:00 0:00:00.512198 354340 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T04:17:56.060939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T03:00:00+00:00 TriggerDagRunOperator 2023-03-16T04:17:58.412276+00:00 2023-03-16T04:17:58.880116+00:00 0:00:00.467840 354339 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T04:17:56.060968+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T03:00:00+00:00 EmrJobFlowSensor 2023-03-16T04:07:47.297779+00:00 2023-03-16T04:17:49.113834+00:00 0:10:01.816055 354335 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T04:07:44.916061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T04:07:25.191891+00:00 2023-03-16T04:07:26.120632+00:00 0:00:00.928741 354332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T04:07:22.830350+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T03:00:00+00:00 PythonOperator 2023-03-16T04:07:05.039961+00:00 2023-03-16T04:07:08.110316+00:00 0:00:03.070355 354329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T04:07:02.802107+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T02:00:00+00:00 TriggerDagRunOperator 2023-03-16T03:23:30.687585+00:00 2023-03-16T03:23:31.251176+00:00 0:00:00.563591 354319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T03:23:27.703169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T02:00:00+00:00 TriggerDagRunOperator 2023-03-16T03:23:30.444321+00:00 2023-03-16T03:23:30.919575+00:00 0:00:00.475254 354318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T03:23:27.703209+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T02:00:00+00:00 EmrJobFlowSensor 2023-03-16T03:00:49.908319+00:00 2023-03-16T03:10:51.849464+00:00 0:10:01.941145 354310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T03:00:47.006796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T03:00:27.271312+00:00 2023-03-16T03:00:28.194685+00:00 0:00:00.923373 354308 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T03:00:24.939454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T02:00:00+00:00 PythonOperator 2023-03-16T03:00:07.713328+00:00 2023-03-16T03:00:10.889602+00:00 0:00:03.176274 354307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T03:00:04.987884+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T01:00:00+00:00 TriggerDagRunOperator 2023-03-16T02:11:12.468542+00:00 2023-03-16T02:11:13.048949+00:00 0:00:00.580407 354297 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T02:11:10.158231+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T01:00:00+00:00 TriggerDagRunOperator 2023-03-16T02:11:12.442396+00:00 2023-03-16T02:11:12.994137+00:00 0:00:00.551741 354296 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T02:11:10.158204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T01:00:00+00:00 EmrJobFlowSensor 2023-03-16T02:00:48.656097+00:00 2023-03-16T02:10:50.567986+00:00 0:10:01.911889 354289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T02:00:46.374129+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T02:00:27.077675+00:00 2023-03-16T02:00:27.945162+00:00 0:00:00.867487 354287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T02:00:24.348538+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T01:00:00+00:00 PythonOperator 2023-03-16T02:00:04.868572+00:00 2023-03-16T02:00:08.177854+00:00 0:00:03.309282 354285 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T02:00:02.333527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-16T00:00:00+00:00 TriggerDagRunOperator 2023-03-16T01:11:19.190539+00:00 2023-03-16T01:11:19.678003+00:00 0:00:00.487464 354269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T01:11:16.203384+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-16T00:00:00+00:00 TriggerDagRunOperator 2023-03-16T01:11:18.907322+00:00 2023-03-16T01:11:19.392947+00:00 0:00:00.485625 354268 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T01:11:16.203413+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-16T00:00:00+00:00 EmrJobFlowSensor 2023-03-16T01:00:56.844105+00:00 2023-03-16T01:10:59.165111+00:00 0:10:02.321006 354261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T01:00:54.464777+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-16T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T01:00:36.675698+00:00 2023-03-16T01:00:37.549778+00:00 0:00:00.874080 354259 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T01:00:34.448926+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-16T00:00:00+00:00 PythonOperator 2023-03-16T01:00:15.693236+00:00 2023-03-16T01:00:19.086406+00:00 0:00:03.393170 354257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T01:00:12.430562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T23:00:00+00:00 TriggerDagRunOperator 2023-03-16T00:11:11.921053+00:00 2023-03-16T00:11:12.504431+00:00 0:00:00.583378 354245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T00:11:09.178685+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T23:00:00+00:00 TriggerDagRunOperator 2023-03-16T00:11:11.770283+00:00 2023-03-16T00:11:12.246683+00:00 0:00:00.476400 354244 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-16T00:11:09.178714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T23:00:00+00:00 EmrJobFlowSensor 2023-03-16T00:00:57.050416+00:00 2023-03-16T00:10:58.836220+00:00 0:10:01.785804 354238 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-16T00:00:54.531892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-16T00:00:36.965432+00:00 2023-03-16T00:00:37.880298+00:00 0:00:00.914866 354236 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-16T00:00:34.511719+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T23:00:00+00:00 PythonOperator 2023-03-16T00:00:14.901146+00:00 2023-03-16T00:00:19.233720+00:00 0:00:04.332574 354234 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-16T00:00:12.503961+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T22:00:00+00:00 TriggerDagRunOperator 2023-03-15T23:11:18.853579+00:00 2023-03-15T23:11:19.469128+00:00 0:00:00.615549 354222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T23:11:16.335953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T22:00:00+00:00 TriggerDagRunOperator 2023-03-15T23:11:18.734734+00:00 2023-03-15T23:11:19.313694+00:00 0:00:00.578960 354221 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T23:11:16.335922+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T22:00:00+00:00 EmrJobFlowSensor 2023-03-15T23:00:56.538843+00:00 2023-03-15T23:10:58.375276+00:00 0:10:01.836433 354213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T23:00:54.242952+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T23:00:34.482198+00:00 2023-03-15T23:00:35.303711+00:00 0:00:00.821513 354210 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T23:00:32.201678+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T22:00:00+00:00 PythonOperator 2023-03-15T23:00:14.870083+00:00 2023-03-15T23:00:20.873635+00:00 0:00:06.003552 354207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T23:00:12.189985+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T21:00:00+00:00 TriggerDagRunOperator 2023-03-15T22:11:19.570627+00:00 2023-03-15T22:11:20.049844+00:00 0:00:00.479217 354196 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T22:11:17.076146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T21:00:00+00:00 TriggerDagRunOperator 2023-03-15T22:11:19.315157+00:00 2023-03-15T22:11:19.774336+00:00 0:00:00.459179 354195 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T22:11:17.076180+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T21:00:00+00:00 EmrJobFlowSensor 2023-03-15T22:00:55.833522+00:00 2023-03-15T22:10:58.180841+00:00 0:10:02.347319 354188 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T22:00:52.904677+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T22:00:33.401715+00:00 2023-03-15T22:00:34.263089+00:00 0:00:00.861374 354186 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T22:00:30.884796+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T21:00:00+00:00 PythonOperator 2023-03-15T22:00:11.686530+00:00 2023-03-15T22:00:17.968633+00:00 0:00:06.282103 354184 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T22:00:08.932969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T20:00:00+00:00 TriggerDagRunOperator 2023-03-15T21:11:10.377808+00:00 2023-03-15T21:11:10.878322+00:00 0:00:00.500514 354173 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T21:11:07.590179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T20:00:00+00:00 TriggerDagRunOperator 2023-03-15T21:11:10.111003+00:00 2023-03-15T21:11:10.690231+00:00 0:00:00.579228 354172 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T21:11:07.590148+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T20:00:00+00:00 EmrJobFlowSensor 2023-03-15T21:00:55.302811+00:00 2023-03-15T21:10:57.105902+00:00 0:10:01.803091 354165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T21:00:53.046264+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T21:00:33.303413+00:00 2023-03-15T21:00:34.143202+00:00 0:00:00.839789 354163 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T21:00:31.030644+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T20:00:00+00:00 PythonOperator 2023-03-15T21:00:11.755527+00:00 2023-03-15T21:00:15.643455+00:00 0:00:03.887928 354161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T21:00:09.090837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T19:00:00+00:00 TriggerDagRunOperator 2023-03-15T20:11:33.742603+00:00 2023-03-15T20:11:34.232500+00:00 0:00:00.489897 354150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T20:11:31.116396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T19:00:00+00:00 TriggerDagRunOperator 2023-03-15T20:11:33.500467+00:00 2023-03-15T20:11:33.981626+00:00 0:00:00.481159 354149 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T20:11:31.116430+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T19:00:00+00:00 EmrJobFlowSensor 2023-03-15T20:01:07.677888+00:00 2023-03-15T20:11:09.525819+00:00 0:10:01.847931 354143 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T20:01:05.203461+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T20:00:45.667070+00:00 2023-03-15T20:00:46.617685+00:00 0:00:00.950615 354141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T20:00:43.209081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T19:00:00+00:00 PythonOperator 2023-03-15T20:00:23.861153+00:00 2023-03-15T20:00:27.157888+00:00 0:00:03.296735 354139 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T20:00:21.221715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T18:00:00+00:00 TriggerDagRunOperator 2023-03-15T19:12:04.584656+00:00 2023-03-15T19:12:05.075171+00:00 0:00:00.490515 354126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T19:12:02.049897+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T18:00:00+00:00 TriggerDagRunOperator 2023-03-15T19:12:04.308487+00:00 2023-03-15T19:12:04.799487+00:00 0:00:00.491000 354125 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T19:12:02.049862+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T18:00:00+00:00 EmrJobFlowSensor 2023-03-15T19:00:48.215244+00:00 2023-03-15T19:11:50.088131+00:00 0:11:01.872887 354118 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T19:00:45.762649+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T19:00:26.465941+00:00 2023-03-15T19:00:27.332067+00:00 0:00:00.866126 354116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T19:00:23.804911+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T18:00:00+00:00 PythonOperator 2023-03-15T19:00:04.357659+00:00 2023-03-15T19:00:08.365934+00:00 0:00:04.008275 354114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T19:00:01.794846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T17:00:00+00:00 TriggerDagRunOperator 2023-03-15T18:11:06.675446+00:00 2023-03-15T18:11:07.195437+00:00 0:00:00.519991 354103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T18:11:04.307465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T17:00:00+00:00 TriggerDagRunOperator 2023-03-15T18:11:06.663349+00:00 2023-03-15T18:11:07.168100+00:00 0:00:00.504751 354102 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T18:11:04.307434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T17:00:00+00:00 EmrJobFlowSensor 2023-03-15T18:00:48.537644+00:00 2023-03-15T18:10:50.252051+00:00 0:10:01.714407 354095 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T18:00:46.343049+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T18:00:26.581434+00:00 2023-03-15T18:00:27.417868+00:00 0:00:00.836434 354093 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T18:00:24.288679+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T17:00:00+00:00 PythonOperator 2023-03-15T18:00:04.567046+00:00 2023-03-15T18:00:07.986575+00:00 0:00:03.419529 354091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T18:00:02.271319+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T16:00:00+00:00 TriggerDagRunOperator 2023-03-15T17:17:21.665890+00:00 2023-03-15T17:17:22.166376+00:00 0:00:00.500486 354081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T17:17:19.081679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T16:00:00+00:00 TriggerDagRunOperator 2023-03-15T17:17:21.664921+00:00 2023-03-15T17:17:22.218270+00:00 0:00:00.553349 354080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T17:17:19.081652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-15T16:00:00+00:00 EmrJobFlowSensor 2023-03-15T17:07:08.969727+00:00 2023-03-15T17:17:10.711509+00:00 0:10:01.741782 354076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-15T17:07:06.777859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-15T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-15T17:06:49.067103+00:00 2023-03-15T17:06:49.973665+00:00 0:00:00.906562 354073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-15T17:06:46.765946+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-15T16:00:00+00:00 PythonOperator 2023-03-15T17:06:27.024054+00:00 2023-03-15T17:06:30.985292+00:00 0:00:03.961238 354070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-15T17:06:24.738842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-15T15:00:00+00:00 TriggerDagRunOperator 2023-03-15T16:12:20.428904+00:00 2023-03-15T16:12:20.916247+00:00 0:00:00.487343 354058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T16:12:17.903979+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-15T15:00:00+00:00 TriggerDagRunOperator 2023-03-15T16:12:20.321324+00:00 2023-03-15T16:12:20.810454+00:00 0:00:00.489130 354057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-15T16:12:17.904008+00:00 2 default_pool