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 trigger_dagrun_campaign-history-job_v002 2023-03-26T11:00:00+00:00 TriggerDagRunOperator 2023-03-26T12:16:26.885866+00:00 2023-03-26T12:16:27.361721+00:00 0:00:00.475855 359442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T12:16:24.554248+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T11:00:00+00:00 EmrJobFlowSensor 2023-03-26T12:01:06.159787+00:00 2023-03-26T12:11:07.938459+00:00 0:10:01.778672 359438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T12:01:03.424826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T12:00:43.657258+00:00 2023-03-26T12:00:44.640593+00:00 0:00:00.983335 359436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T12:00:41.397815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T11:00:00+00:00 PythonOperator 2023-03-26T12:00:21.529663+00:00 2023-03-26T12:00:25.557377+00:00 0:00:04.027714 359434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T12:00:19.377772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T10:00:00+00:00 TriggerDagRunOperator 2023-03-26T11:13:38.417663+00:00 2023-03-26T11:13:38.906145+00:00 0:00:00.488482 359425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T11:13:35.654779+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T10:00:00+00:00 TriggerDagRunOperator 2023-03-26T11:13:38.239264+00:00 2023-03-26T11:13:38.708684+00:00 0:00:00.469420 359424 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T11:13:35.654749+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T10:00:00+00:00 EmrJobFlowSensor 2023-03-26T11:01:04.754794+00:00 2023-03-26T11:11:06.690510+00:00 0:10:01.935716 359420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T11:01:02.388892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T11:00:44.641917+00:00 2023-03-26T11:00:45.642195+00:00 0:00:01.000278 359418 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T11:00:42.335498+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T10:00:00+00:00 PythonOperator 2023-03-26T11:00:22.648631+00:00 2023-03-26T11:00:25.994646+00:00 0:00:03.346015 359416 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T11:00:20.306745+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T09:00:00+00:00 TriggerDagRunOperator 2023-03-26T10:21:07.503075+00:00 2023-03-26T10:21:08.029904+00:00 0:00:00.526829 359407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T10:21:04.727381+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T09:00:00+00:00 TriggerDagRunOperator 2023-03-26T10:21:07.406991+00:00 2023-03-26T10:21:07.882018+00:00 0:00:00.475027 359406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T10:21:04.727353+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T09:00:00+00:00 EmrJobFlowSensor 2023-03-26T10:10:57.063249+00:00 2023-03-26T10:20:58.716165+00:00 0:10:01.652916 359403 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T10:10:54.895653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T10:10:35.098044+00:00 2023-03-26T10:10:36.030246+00:00 0:00:00.932202 359400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T10:10:32.874298+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T09:00:00+00:00 PythonOperator 2023-03-26T10:10:13.407580+00:00 2023-03-26T10:10:16.735105+00:00 0:00:03.327525 359397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T10:10:10.853705+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T08:00:00+00:00 TriggerDagRunOperator 2023-03-26T09:19:39.694571+00:00 2023-03-26T09:19:40.223188+00:00 0:00:00.528617 359389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T09:19:36.778622+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T08:00:00+00:00 TriggerDagRunOperator 2023-03-26T09:19:39.495738+00:00 2023-03-26T09:19:39.967012+00:00 0:00:00.471274 359388 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T09:19:36.778659+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T08:00:00+00:00 EmrJobFlowSensor 2023-03-26T09:02:35.227674+00:00 2023-03-26T09:12:36.982504+00:00 0:10:01.754830 359382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T09:02:32.830112+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T09:02:16.898249+00:00 2023-03-26T09:02:17.964541+00:00 0:00:01.066292 359380 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T09:02:12.813751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T08:00:00+00:00 PythonOperator 2023-03-26T09:01:53.215590+00:00 2023-03-26T09:01:56.678252+00:00 0:00:03.462662 359378 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T09:01:50.802696+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T07:00:00+00:00 TriggerDagRunOperator 2023-03-26T08:28:26.354854+00:00 2023-03-26T08:28:26.856035+00:00 0:00:00.501181 359371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T08:28:23.511956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T07:00:00+00:00 TriggerDagRunOperator 2023-03-26T08:28:26.289703+00:00 2023-03-26T08:28:26.758083+00:00 0:00:00.468380 359370 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T08:28:23.511924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T07:00:00+00:00 EmrJobFlowSensor 2023-03-26T08:08:16.212114+00:00 2023-03-26T08:18:18.061450+00:00 0:10:01.849336 359365 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T08:08:13.932101+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T08:07:56.221092+00:00 2023-03-26T08:07:57.162048+00:00 0:00:00.940956 359362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T08:07:53.874487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T07:00:00+00:00 PythonOperator 2023-03-26T08:07:34.973408+00:00 2023-03-26T08:07:38.582118+00:00 0:00:03.608710 359359 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T08:07:31.838200+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T06:00:00+00:00 TriggerDagRunOperator 2023-03-26T07:29:51.512229+00:00 2023-03-26T07:29:51.986212+00:00 0:00:00.473983 359353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T07:29:48.660466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T06:00:00+00:00 TriggerDagRunOperator 2023-03-26T07:29:51.257981+00:00 2023-03-26T07:29:51.723370+00:00 0:00:00.465389 359352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T07:29:48.660438+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T06:00:00+00:00 EmrJobFlowSensor 2023-03-26T07:08:19.006260+00:00 2023-03-26T07:18:20.803420+00:00 0:10:01.797160 359346 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T07:08:16.682316+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T07:07:56.910209+00:00 2023-03-26T07:07:57.737068+00:00 0:00:00.826859 359342 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T07:07:54.624824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T05:00:00+00:00 TriggerDagRunOperator 2023-03-26T07:07:39.663620+00:00 2023-03-26T07:07:40.294714+00:00 0:00:00.631094 359338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T07:07:34.210083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T05:00:00+00:00 TriggerDagRunOperator 2023-03-26T07:07:39.610665+00:00 2023-03-26T07:07:40.237745+00:00 0:00:00.627080 359337 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T07:07:34.210049+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T06:00:00+00:00 PythonOperator 2023-03-26T07:07:37.154996+00:00 2023-03-26T07:07:40.633862+00:00 0:00:03.478866 359336 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T07:07:34.210098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T05:00:00+00:00 EmrJobFlowSensor 2023-03-26T06:49:39.540702+00:00 2023-03-26T06:58:41.136597+00:00 0:09:01.595895 359333 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T06:49:37.377310+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T06:49:17.945840+00:00 2023-03-26T06:49:18.839605+00:00 0:00:00.893765 359330 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T06:49:15.360119+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T05:00:00+00:00 PythonOperator 2023-03-26T06:48:55.539289+00:00 2023-03-26T06:49:00.094982+00:00 0:00:04.555693 359327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T06:48:53.299758+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T04:00:00+00:00 TriggerDagRunOperator 2023-03-26T05:12:26.153044+00:00 2023-03-26T05:12:26.663486+00:00 0:00:00.510442 359319 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T05:12:23.519156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T04:00:00+00:00 TriggerDagRunOperator 2023-03-26T05:12:26.101861+00:00 2023-03-26T05:12:26.596574+00:00 0:00:00.494713 359318 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T05:12:23.519185+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T04:00:00+00:00 EmrJobFlowSensor 2023-03-26T05:02:12.597307+00:00 2023-03-26T05:12:14.472348+00:00 0:10:01.875041 359311 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T05:02:10.262017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T05:01:52.625937+00:00 2023-03-26T05:01:53.645149+00:00 0:00:01.019212 359309 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T05:01:50.240736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T04:00:00+00:00 PythonOperator 2023-03-26T05:01:30.822251+00:00 2023-03-26T05:01:34.537665+00:00 0:00:03.715414 359307 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T05:01:28.223050+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T03:00:00+00:00 TriggerDagRunOperator 2023-03-26T04:15:06.685160+00:00 2023-03-26T04:15:07.399640+00:00 0:00:00.714480 359295 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T04:15:01.499140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T03:00:00+00:00 TriggerDagRunOperator 2023-03-26T04:15:06.637633+00:00 2023-03-26T04:15:07.269041+00:00 0:00:00.631408 359294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T04:15:01.499110+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T03:00:00+00:00 EmrJobFlowSensor 2023-03-26T04:00:55.242207+00:00 2023-03-26T04:10:57.192068+00:00 0:10:01.949861 359291 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T04:00:52.574408+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T04:00:32.834841+00:00 2023-03-26T04:00:33.670105+00:00 0:00:00.835264 359289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T04:00:30.557391+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T03:00:00+00:00 PythonOperator 2023-03-26T04:00:11.372107+00:00 2023-03-26T04:00:14.622604+00:00 0:00:03.250497 359287 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T04:00:08.598372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T02:00:00+00:00 TriggerDagRunOperator 2023-03-26T03:11:09.128893+00:00 2023-03-26T03:11:09.607009+00:00 0:00:00.478116 359278 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T03:11:06.836385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T02:00:00+00:00 TriggerDagRunOperator 2023-03-26T03:11:09.048761+00:00 2023-03-26T03:11:09.520320+00:00 0:00:00.471559 359277 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T03:11:06.836355+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T02:00:00+00:00 EmrJobFlowSensor 2023-03-26T03:00:53.550841+00:00 2023-03-26T03:10:55.392312+00:00 0:10:01.841471 359271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T03:00:51.249586+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T03:00:33.128547+00:00 2023-03-26T03:00:34.471243+00:00 0:00:01.342696 359269 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T03:00:29.236238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T02:00:00+00:00 PythonOperator 2023-03-26T03:00:11.351454+00:00 2023-03-26T03:00:16.110929+00:00 0:00:04.759475 359267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T03:00:09.144911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T01:00:00+00:00 TriggerDagRunOperator 2023-03-26T02:22:18.425033+00:00 2023-03-26T02:22:18.951283+00:00 0:00:00.526250 359258 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T02:22:15.229215+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T01:00:00+00:00 TriggerDagRunOperator 2023-03-26T02:22:18.420927+00:00 2023-03-26T02:22:18.977571+00:00 0:00:00.556644 359257 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T02:22:15.229177+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T01:00:00+00:00 EmrJobFlowSensor 2023-03-26T02:00:55.422994+00:00 2023-03-26T02:10:57.310774+00:00 0:10:01.887780 359249 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T02:00:52.907178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T02:00:33.607664+00:00 2023-03-26T02:00:34.482623+00:00 0:00:00.874959 359247 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T02:00:30.911787+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T01:00:00+00:00 PythonOperator 2023-03-26T02:00:11.128401+00:00 2023-03-26T02:00:15.108778+00:00 0:00:03.980377 359245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T02:00:08.741491+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-26T00:00:00+00:00 TriggerDagRunOperator 2023-03-26T01:12:44.762411+00:00 2023-03-26T01:12:45.466256+00:00 0:00:00.703845 359231 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T01:12:42.333837+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-26T00:00:00+00:00 TriggerDagRunOperator 2023-03-26T01:12:44.732442+00:00 2023-03-26T01:12:45.411130+00:00 0:00:00.678688 359230 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T01:12:42.333864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-26T00:00:00+00:00 EmrJobFlowSensor 2023-03-26T01:02:31.679751+00:00 2023-03-26T01:12:33.472745+00:00 0:10:01.792994 359224 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T01:02:29.381482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-26T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T01:02:09.665043+00:00 2023-03-26T01:02:10.871730+00:00 0:00:01.206687 359222 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T01:02:07.359561+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-26T00:00:00+00:00 PythonOperator 2023-03-26T01:01:50.095130+00:00 2023-03-26T01:01:54.689699+00:00 0:00:04.594569 359219 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T01:01:47.236070+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T23:00:00+00:00 TriggerDagRunOperator 2023-03-26T00:21:11.549171+00:00 2023-03-26T00:21:12.043384+00:00 0:00:00.494213 359211 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T00:21:08.836137+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T23:00:00+00:00 TriggerDagRunOperator 2023-03-26T00:21:11.453348+00:00 2023-03-26T00:21:11.902052+00:00 0:00:00.448704 359210 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-26T00:21:08.836166+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T23:00:00+00:00 EmrJobFlowSensor 2023-03-26T00:02:06.331343+00:00 2023-03-26T00:12:08.172962+00:00 0:10:01.841619 359203 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-26T00:02:03.932694+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-26T00:01:46.214363+00:00 2023-03-26T00:01:47.063740+00:00 0:00:00.849377 359201 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-26T00:01:43.877975+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T23:00:00+00:00 PythonOperator 2023-03-26T00:01:24.970053+00:00 2023-03-26T00:01:29.944980+00:00 0:00:04.974927 359199 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-26T00:01:21.829019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T22:00:00+00:00 TriggerDagRunOperator 2023-03-25T23:11:53.996534+00:00 2023-03-25T23:11:54.521176+00:00 0:00:00.524642 359190 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T23:11:51.077389+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T22:00:00+00:00 TriggerDagRunOperator 2023-03-25T23:11:53.681565+00:00 2023-03-25T23:11:54.163965+00:00 0:00:00.482400 359189 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T23:11:51.077361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T22:00:00+00:00 EmrJobFlowSensor 2023-03-25T23:01:00.819228+00:00 2023-03-25T23:11:02.707877+00:00 0:10:01.888649 359182 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T23:00:58.540787+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T23:00:40.820387+00:00 2023-03-25T23:00:42.021989+00:00 0:00:01.201602 359179 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T23:00:38.508542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T22:00:00+00:00 PythonOperator 2023-03-25T23:00:18.697605+00:00 2023-03-25T23:00:22.221522+00:00 0:00:03.523917 359176 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T23:00:16.492940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T21:00:00+00:00 TriggerDagRunOperator 2023-03-25T22:11:02.508769+00:00 2023-03-25T22:11:02.987676+00:00 0:00:00.478907 359165 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T22:10:59.641475+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T21:00:00+00:00 TriggerDagRunOperator 2023-03-25T22:11:02.123636+00:00 2023-03-25T22:11:02.639702+00:00 0:00:00.516066 359164 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T22:10:59.641513+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T21:00:00+00:00 EmrJobFlowSensor 2023-03-25T22:00:55.695693+00:00 2023-03-25T22:10:57.515027+00:00 0:10:01.819334 359157 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T22:00:53.353799+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T22:00:33.734986+00:00 2023-03-25T22:00:34.626268+00:00 0:00:00.891282 359155 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T22:00:31.328824+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T21:00:00+00:00 PythonOperator 2023-03-25T22:00:13.928854+00:00 2023-03-25T22:00:17.915621+00:00 0:00:03.986767 359153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T22:00:11.358202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T20:00:00+00:00 TriggerDagRunOperator 2023-03-25T21:11:25.894474+00:00 2023-03-25T21:11:26.705378+00:00 0:00:00.810904 359142 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T21:11:23.229645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T20:00:00+00:00 TriggerDagRunOperator 2023-03-25T21:11:25.682851+00:00 2023-03-25T21:11:26.614217+00:00 0:00:00.931366 359141 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T21:11:23.229675+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T20:00:00+00:00 EmrJobFlowSensor 2023-03-25T21:01:04.553288+00:00 2023-03-25T21:11:06.458409+00:00 0:10:01.905121 359135 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T21:01:01.302914+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T21:00:41.707234+00:00 2023-03-25T21:00:42.507967+00:00 0:00:00.800733 359133 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T21:00:39.208076+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T20:00:00+00:00 PythonOperator 2023-03-25T21:00:17.371109+00:00 2023-03-25T21:00:21.047272+00:00 0:00:03.676163 359131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T21:00:15.123179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T19:00:00+00:00 TriggerDagRunOperator 2023-03-25T20:11:45.994027+00:00 2023-03-25T20:11:46.479149+00:00 0:00:00.485122 359120 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T20:11:43.567014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T19:00:00+00:00 TriggerDagRunOperator 2023-03-25T20:11:45.977743+00:00 2023-03-25T20:11:46.458720+00:00 0:00:00.480977 359119 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T20:11:43.567042+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T19:00:00+00:00 EmrJobFlowSensor 2023-03-25T20:00:47.307319+00:00 2023-03-25T20:10:49.113118+00:00 0:10:01.805799 359111 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T20:00:44.977864+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T20:00:25.205263+00:00 2023-03-25T20:00:26.077158+00:00 0:00:00.871895 359109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T20:00:22.958189+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T19:00:00+00:00 PythonOperator 2023-03-25T20:00:05.153063+00:00 2023-03-25T20:00:11.692839+00:00 0:00:06.539776 359107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T20:00:02.893346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T18:00:00+00:00 TriggerDagRunOperator 2023-03-25T19:30:51.728875+00:00 2023-03-25T19:30:52.187412+00:00 0:00:00.458537 359101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T19:30:49.030167+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T18:00:00+00:00 TriggerDagRunOperator 2023-03-25T19:30:51.621749+00:00 2023-03-25T19:30:52.093805+00:00 0:00:00.472056 359100 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T19:30:49.030194+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T18:00:00+00:00 EmrJobFlowSensor 2023-03-25T19:12:14.488699+00:00 2023-03-25T19:22:16.277973+00:00 0:10:01.789274 359097 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T19:12:11.891953+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T19:11:52.861298+00:00 2023-03-25T19:11:53.841934+00:00 0:00:00.980636 359094 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T19:11:49.852294+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T18:00:00+00:00 PythonOperator 2023-03-25T19:11:31.297973+00:00 2023-03-25T19:11:34.732911+00:00 0:00:03.434938 359091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T19:11:27.829522+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T17:00:00+00:00 TriggerDagRunOperator 2023-03-25T18:11:13.183886+00:00 2023-03-25T18:11:13.736031+00:00 0:00:00.552145 359081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T18:11:10.786085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T17:00:00+00:00 TriggerDagRunOperator 2023-03-25T18:11:13.027573+00:00 2023-03-25T18:11:13.544644+00:00 0:00:00.517071 359080 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T18:11:10.786130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T17:00:00+00:00 EmrJobFlowSensor 2023-03-25T18:00:54.766931+00:00 2023-03-25T18:10:57.315865+00:00 0:10:02.548934 359073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T18:00:52.240108+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T18:00:32.342534+00:00 2023-03-25T18:00:33.163163+00:00 0:00:00.820629 359071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T18:00:30.181309+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T17:00:00+00:00 PythonOperator 2023-03-25T18:00:10.781093+00:00 2023-03-25T18:00:16.533465+00:00 0:00:05.752372 359069 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T18:00:08.161578+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-25T16:00:00+00:00 TriggerDagRunOperator 2023-03-25T17:25:20.682804+00:00 2023-03-25T17:25:21.225672+00:00 0:00:00.542868 359063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T17:25:18.069390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T16:00:00+00:00 TriggerDagRunOperator 2023-03-25T17:25:20.599771+00:00 2023-03-25T17:25:21.131916+00:00 0:00:00.532145 359062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T17:25:18.069361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-25T16:00:00+00:00 EmrJobFlowSensor 2023-03-25T17:12:32.486782+00:00 2023-03-25T17:22:34.390694+00:00 0:10:01.903912 359057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-25T17:12:30.066488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-25T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-25T17:12:12.716112+00:00 2023-03-25T17:12:13.568043+00:00 0:00:00.851931 359054 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-25T17:12:10.041471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-25T16:00:00+00:00 PythonOperator 2023-03-25T17:11:50.689037+00:00 2023-03-25T17:11:54.467124+00:00 0:00:03.778087 359051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-25T17:11:48.076000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-25T15:00:00+00:00 TriggerDagRunOperator 2023-03-25T16:45:25.957883+00:00 2023-03-25T16:45:26.532395+00:00 0:00:00.574512 359045 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-25T16:45:22.944141+00:00 2 default_pool