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-02-26T16:00:00+00:00 EmrJobFlowSensor 2023-02-26T17:12:20.778123+00:00 2023-02-26T17:22:22.542292+00:00 0:10:01.764169 345676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T17:12:18.540433+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T17:12:00.807789+00:00 2023-02-26T17:12:01.636547+00:00 0:00:00.828758 345673 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T17:11:58.474721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T16:00:00+00:00 PythonOperator 2023-02-26T17:11:39.531511+00:00 2023-02-26T17:11:45.540713+00:00 0:00:06.009202 345670 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T17:11:36.453011+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T15:00:00+00:00 TriggerDagRunOperator 2023-02-26T16:48:57.054771+00:00 2023-02-26T16:48:57.559340+00:00 0:00:00.504569 345663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T16:48:53.724857+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T15:00:00+00:00 TriggerDagRunOperator 2023-02-26T16:48:56.679734+00:00 2023-02-26T16:48:57.204946+00:00 0:00:00.525212 345662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T16:48:53.724887+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T15:00:00+00:00 EmrJobFlowSensor 2023-02-26T16:38:44.722297+00:00 2023-02-26T16:48:46.971578+00:00 0:10:02.249281 345655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T16:38:42.196307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T16:38:22.361252+00:00 2023-02-26T16:38:23.477199+00:00 0:00:01.115947 345650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T16:38:20.175162+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T15:00:00+00:00 PythonOperator 2023-02-26T16:38:00.841216+00:00 2023-02-26T16:38:04.791471+00:00 0:00:03.950255 345647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T16:37:58.161956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T13:00:00+00:00 TriggerDagRunOperator 2023-02-26T14:56:08.923508+00:00 2023-02-26T14:56:09.480093+00:00 0:00:00.556585 345642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T14:56:06.445708+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T13:00:00+00:00 TriggerDagRunOperator 2023-02-26T14:56:08.815285+00:00 2023-02-26T14:56:09.394637+00:00 0:00:00.579352 345641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T14:56:06.445666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T13:00:00+00:00 EmrJobFlowSensor 2023-02-26T14:42:36.392716+00:00 2023-02-26T14:52:38.318567+00:00 0:10:01.925851 345636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T14:42:34.075304+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T14:42:16.506838+00:00 2023-02-26T14:42:17.454597+00:00 0:00:00.947759 345633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T14:42:14.058699+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T13:00:00+00:00 PythonOperator 2023-02-26T14:41:54.627155+00:00 2023-02-26T14:41:58.507531+00:00 0:00:03.880376 345630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T14:41:52.039524+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T12:00:00+00:00 TriggerDagRunOperator 2023-02-26T13:55:22.541769+00:00 2023-02-26T13:55:23.070804+00:00 0:00:00.529035 345625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T13:55:20.047155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T12:00:00+00:00 TriggerDagRunOperator 2023-02-26T13:55:22.514113+00:00 2023-02-26T13:55:23.072951+00:00 0:00:00.558838 345624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T13:55:20.047125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T12:00:00+00:00 EmrJobFlowSensor 2023-02-26T13:40:40.376524+00:00 2023-02-26T13:50:42.183669+00:00 0:10:01.807145 345614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T13:40:37.522382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T13:40:17.812970+00:00 2023-02-26T13:40:18.712383+00:00 0:00:00.899413 345609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T13:40:15.426648+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T12:00:00+00:00 PythonOperator 2023-02-26T13:39:58.894102+00:00 2023-02-26T13:40:03.125517+00:00 0:00:04.231415 345606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T13:39:52.918568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T10:00:00+00:00 TriggerDagRunOperator 2023-02-26T13:39:58.732015+00:00 2023-02-26T13:39:59.370031+00:00 0:00:00.638016 345605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T13:39:52.918510+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T10:00:00+00:00 TriggerDagRunOperator 2023-02-26T13:39:55.784617+00:00 2023-02-26T13:39:56.243554+00:00 0:00:00.458937 345604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T13:39:52.918550+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T10:00:00+00:00 EmrJobFlowSensor 2023-02-26T11:02:05.445267+00:00 2023-02-26T11:12:07.135914+00:00 0:10:01.690647 345599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T11:02:02.921735+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T11:01:43.139899+00:00 2023-02-26T11:01:44.038202+00:00 0:00:00.898303 345595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T11:01:40.861147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T09:00:00+00:00 TriggerDagRunOperator 2023-02-26T11:01:26.804592+00:00 2023-02-26T11:01:27.417625+00:00 0:00:00.613033 345593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T11:01:20.840025+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T09:00:00+00:00 TriggerDagRunOperator 2023-02-26T11:01:26.475706+00:00 2023-02-26T11:01:27.226169+00:00 0:00:00.750463 345592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T11:01:20.839996+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T10:00:00+00:00 PythonOperator 2023-02-26T11:01:23.431148+00:00 2023-02-26T11:01:27.263526+00:00 0:00:03.832378 345591 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T11:01:20.840039+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T09:00:00+00:00 EmrJobFlowSensor 2023-02-26T10:11:14.063716+00:00 2023-02-26T10:21:15.978326+00:00 0:10:01.914610 345582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T10:11:11.731582+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T10:10:52.438909+00:00 2023-02-26T10:10:53.342634+00:00 0:00:00.903725 345578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T10:10:49.799306+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T09:00:00+00:00 PythonOperator 2023-02-26T10:10:37.852406+00:00 2023-02-26T10:10:46.809988+00:00 0:00:08.957582 345574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T10:10:29.358436+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T07:00:00+00:00 TriggerDagRunOperator 2023-02-26T10:10:37.409103+00:00 2023-02-26T10:10:38.317536+00:00 0:00:00.908433 345573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T10:10:29.358409+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T07:00:00+00:00 TriggerDagRunOperator 2023-02-26T10:10:32.480830+00:00 2023-02-26T10:10:32.990454+00:00 0:00:00.509624 345571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T10:10:29.358375+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T07:00:00+00:00 EmrJobFlowSensor 2023-02-26T08:23:38.784567+00:00 2023-02-26T08:33:40.584000+00:00 0:10:01.799433 345566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T08:23:36.535173+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T08:23:18.860950+00:00 2023-02-26T08:23:19.698082+00:00 0:00:00.837132 345563 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T08:23:16.494311+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T07:00:00+00:00 PythonOperator 2023-02-26T08:22:57.248309+00:00 2023-02-26T08:23:01.069164+00:00 0:00:03.820855 345560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T08:22:54.482785+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T06:00:00+00:00 TriggerDagRunOperator 2023-02-26T07:13:45.174314+00:00 2023-02-26T07:13:45.711014+00:00 0:00:00.536700 345555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T07:13:42.437989+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T06:00:00+00:00 TriggerDagRunOperator 2023-02-26T07:13:44.920149+00:00 2023-02-26T07:13:45.588729+00:00 0:00:00.668580 345554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T07:13:42.437960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T06:00:00+00:00 EmrJobFlowSensor 2023-02-26T07:03:24.681820+00:00 2023-02-26T07:13:26.474322+00:00 0:10:01.792502 345537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T07:03:22.132789+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T07:03:02.498355+00:00 2023-02-26T07:03:03.384064+00:00 0:00:00.885709 345534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T07:03:00.158207+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T06:00:00+00:00 PythonOperator 2023-02-26T07:02:41.231369+00:00 2023-02-26T07:02:46.798853+00:00 0:00:05.567484 345530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T07:02:38.119141+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-26T00:00:00+00:00 TriggerDagRunOperator 2023-02-26T01:32:29.320290+00:00 2023-02-26T01:32:29.835314+00:00 0:00:00.515024 345523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T01:32:25.005410+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-26T00:00:00+00:00 TriggerDagRunOperator 2023-02-26T01:32:27.547520+00:00 2023-02-26T01:32:28.007763+00:00 0:00:00.460243 345522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T01:32:25.005444+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-26T00:00:00+00:00 EmrJobFlowSensor 2023-02-26T01:01:22.607213+00:00 2023-02-26T01:11:24.347607+00:00 0:10:01.740394 345513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T01:01:20.223245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-26T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T01:01:00.416507+00:00 2023-02-26T01:01:01.287597+00:00 0:00:00.871090 345511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T01:00:58.203304+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-26T00:00:00+00:00 PythonOperator 2023-02-26T01:00:41.254834+00:00 2023-02-26T01:00:45.242807+00:00 0:00:03.987973 345509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T01:00:38.205819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T23:00:00+00:00 TriggerDagRunOperator 2023-02-26T00:44:02.885088+00:00 2023-02-26T00:44:03.499391+00:00 0:00:00.614303 345504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T00:43:59.855619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T23:00:00+00:00 TriggerDagRunOperator 2023-02-26T00:44:02.632227+00:00 2023-02-26T00:44:03.237774+00:00 0:00:00.605547 345503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-26T00:43:59.855648+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T23:00:00+00:00 EmrJobFlowSensor 2023-02-26T00:26:08.397689+00:00 2023-02-26T00:36:10.213302+00:00 0:10:01.815613 345498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-26T00:26:05.483406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-26T00:25:47.946465+00:00 2023-02-26T00:25:48.825698+00:00 0:00:00.879233 345495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-26T00:25:45.471274+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T23:00:00+00:00 PythonOperator 2023-02-26T00:25:26.314272+00:00 2023-02-26T00:25:30.245715+00:00 0:00:03.931443 345492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-26T00:25:23.449970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T22:00:00+00:00 TriggerDagRunOperator 2023-02-25T23:25:42.378583+00:00 2023-02-25T23:25:42.878481+00:00 0:00:00.499898 345484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T23:25:39.724302+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T22:00:00+00:00 TriggerDagRunOperator 2023-02-25T23:25:42.208410+00:00 2023-02-25T23:25:42.724185+00:00 0:00:00.515775 345483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T23:25:39.724272+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T22:00:00+00:00 EmrJobFlowSensor 2023-02-25T23:06:39.213171+00:00 2023-02-25T23:16:41.035282+00:00 0:10:01.822111 345480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T23:06:36.944236+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T23:06:24.139082+00:00 2023-02-25T23:06:25.151814+00:00 0:00:01.012732 345476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T23:06:16.881857+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T22:00:00+00:00 PythonOperator 2023-02-25T23:06:01.200321+00:00 2023-02-25T23:06:07.317126+00:00 0:00:06.116805 345472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T23:05:54.861787+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T21:00:00+00:00 TriggerDagRunOperator 2023-02-25T22:12:17.867914+00:00 2023-02-25T22:12:18.370040+00:00 0:00:00.502126 345458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T22:12:15.321532+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T21:00:00+00:00 TriggerDagRunOperator 2023-02-25T22:12:17.832481+00:00 2023-02-25T22:12:18.357708+00:00 0:00:00.525227 345457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T22:12:15.321502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T21:00:00+00:00 EmrJobFlowSensor 2023-02-25T22:01:53.899024+00:00 2023-02-25T22:11:55.822795+00:00 0:10:01.923771 345450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T22:01:51.501663+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T22:01:33.822754+00:00 2023-02-25T22:01:34.723665+00:00 0:00:00.900911 345448 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T22:01:31.485140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T21:00:00+00:00 PythonOperator 2023-02-25T22:01:12.047021+00:00 2023-02-25T22:01:18.284019+00:00 0:00:06.236998 345446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T22:01:09.513492+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T20:00:00+00:00 TriggerDagRunOperator 2023-02-25T21:11:18.319361+00:00 2023-02-25T21:11:18.785421+00:00 0:00:00.466060 345436 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T21:11:15.122608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T20:00:00+00:00 TriggerDagRunOperator 2023-02-25T21:11:18.032234+00:00 2023-02-25T21:11:18.515937+00:00 0:00:00.483703 345435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T21:11:15.122636+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T20:00:00+00:00 EmrJobFlowSensor 2023-02-25T21:00:59.762670+00:00 2023-02-25T21:11:02.005160+00:00 0:10:02.242490 345427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T21:00:57.507631+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T21:00:37.656859+00:00 2023-02-25T21:00:38.482948+00:00 0:00:00.826089 345425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T21:00:35.487730+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T20:00:00+00:00 PythonOperator 2023-02-25T21:00:16.025875+00:00 2023-02-25T21:00:19.832518+00:00 0:00:03.806643 345423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T21:00:13.469667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T19:00:00+00:00 TriggerDagRunOperator 2023-02-25T20:12:51.228057+00:00 2023-02-25T20:12:51.733154+00:00 0:00:00.505097 345416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T20:12:48.490924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T19:00:00+00:00 TriggerDagRunOperator 2023-02-25T20:12:51.197820+00:00 2023-02-25T20:12:51.676834+00:00 0:00:00.479014 345415 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T20:12:48.490978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T19:00:00+00:00 EmrJobFlowSensor 2023-02-25T20:02:26.223169+00:00 2023-02-25T20:12:27.993021+00:00 0:10:01.769852 345408 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T20:02:23.982132+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T20:02:06.696746+00:00 2023-02-25T20:02:07.562347+00:00 0:00:00.865601 345406 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T20:02:03.970865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T19:00:00+00:00 PythonOperator 2023-02-25T20:01:44.894975+00:00 2023-02-25T20:01:48.983989+00:00 0:00:04.089014 345404 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T20:01:41.932283+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T18:00:00+00:00 TriggerDagRunOperator 2023-02-25T19:28:50.486509+00:00 2023-02-25T19:28:51.110062+00:00 0:00:00.623553 345398 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T19:28:47.516194+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T18:00:00+00:00 TriggerDagRunOperator 2023-02-25T19:28:50.438850+00:00 2023-02-25T19:28:50.979587+00:00 0:00:00.540737 345397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T19:28:47.516229+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T18:00:00+00:00 EmrJobFlowSensor 2023-02-25T19:01:06.108643+00:00 2023-02-25T19:11:07.890614+00:00 0:10:01.781971 345390 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T19:01:03.886697+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T19:00:44.484593+00:00 2023-02-25T19:00:45.536742+00:00 0:00:01.052149 345388 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T19:00:41.872515+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T18:00:00+00:00 PythonOperator 2023-02-25T19:00:22.181497+00:00 2023-02-25T19:00:25.285700+00:00 0:00:03.104203 345386 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T19:00:19.846400+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T17:00:00+00:00 TriggerDagRunOperator 2023-02-25T18:16:28.144575+00:00 2023-02-25T18:16:28.667817+00:00 0:00:00.523242 345376 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T18:16:25.540271+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T17:00:00+00:00 TriggerDagRunOperator 2023-02-25T18:16:27.957472+00:00 2023-02-25T18:16:28.426226+00:00 0:00:00.468754 345375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T18:16:25.540244+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T17:00:00+00:00 EmrJobFlowSensor 2023-02-25T18:06:14.505094+00:00 2023-02-25T18:16:16.466609+00:00 0:10:01.961515 345372 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T18:06:12.205532+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T18:05:52.552490+00:00 2023-02-25T18:05:53.609785+00:00 0:00:01.057295 345369 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T18:05:50.185473+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T17:00:00+00:00 PythonOperator 2023-02-25T18:05:33.406783+00:00 2023-02-25T18:05:36.628431+00:00 0:00:03.221648 345366 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T18:05:30.156659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T16:00:00+00:00 TriggerDagRunOperator 2023-02-25T17:11:26.609202+00:00 2023-02-25T17:11:27.105358+00:00 0:00:00.496156 345355 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T17:11:23.845085+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T16:00:00+00:00 TriggerDagRunOperator 2023-02-25T17:11:26.485703+00:00 2023-02-25T17:11:26.991118+00:00 0:00:00.505415 345354 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T17:11:23.845115+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T16:00:00+00:00 EmrJobFlowSensor 2023-02-25T17:01:06.189881+00:00 2023-02-25T17:11:07.996169+00:00 0:10:01.806288 345347 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T17:01:03.890720+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T17:00:44.370347+00:00 2023-02-25T17:00:45.349783+00:00 0:00:00.979436 345345 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T17:00:41.865179+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T16:00:00+00:00 PythonOperator 2023-02-25T17:00:24.240800+00:00 2023-02-25T17:00:28.158618+00:00 0:00:03.917818 345343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T17:00:21.910804+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T15:00:00+00:00 TriggerDagRunOperator 2023-02-25T16:16:54.421827+00:00 2023-02-25T16:16:55.240747+00:00 0:00:00.818920 345334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T16:16:50.844134+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T15:00:00+00:00 TriggerDagRunOperator 2023-02-25T16:16:53.194128+00:00 2023-02-25T16:16:53.697789+00:00 0:00:00.503661 345333 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T16:16:50.844168+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T15:00:00+00:00 EmrJobFlowSensor 2023-02-25T16:01:01.462247+00:00 2023-02-25T16:11:03.320414+00:00 0:10:01.858167 345329 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T16:00:59.064017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T16:00:39.415931+00:00 2023-02-25T16:00:40.270176+00:00 0:00:00.854245 345327 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T16:00:37.044792+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T15:00:00+00:00 PythonOperator 2023-02-25T16:00:17.572376+00:00 2023-02-25T16:00:21.725404+00:00 0:00:04.153028 345325 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T16:00:15.103761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T14:00:00+00:00 TriggerDagRunOperator 2023-02-25T15:58:49.713371+00:00 2023-02-25T15:58:50.227532+00:00 0:00:00.514161 345320 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T15:58:46.908731+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T14:00:00+00:00 TriggerDagRunOperator 2023-02-25T15:58:49.410125+00:00 2023-02-25T15:58:49.903644+00:00 0:00:00.493519 345319 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T15:58:46.908764+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T14:00:00+00:00 EmrJobFlowSensor 2023-02-25T15:41:49.113975+00:00 2023-02-25T15:51:51.006673+00:00 0:10:01.892698 345310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T15:41:45.151160+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T15:41:25.340392+00:00 2023-02-25T15:41:26.137104+00:00 0:00:00.796712 345305 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T15:41:23.066249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T14:00:00+00:00 PythonOperator 2023-02-25T15:41:06.057710+00:00 2023-02-25T15:41:09.326065+00:00 0:00:03.268355 345301 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T15:41:03.046142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T11:00:00+00:00 TriggerDagRunOperator 2023-02-25T12:53:26.630783+00:00 2023-02-25T12:53:27.169381+00:00 0:00:00.538598 345295 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T12:53:23.544580+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T11:00:00+00:00 TriggerDagRunOperator 2023-02-25T12:53:26.480572+00:00 2023-02-25T12:53:27.016644+00:00 0:00:00.536072 345294 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T12:53:23.544541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-25T11:00:00+00:00 EmrJobFlowSensor 2023-02-25T12:18:59.556813+00:00 2023-02-25T12:29:01.333994+00:00 0:10:01.777181 345289 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-25T12:18:57.246312+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-25T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-25T12:18:39.613594+00:00 2023-02-25T12:18:40.558515+00:00 0:00:00.944921 345286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-25T12:18:37.228454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-25T11:00:00+00:00 PythonOperator 2023-02-25T12:18:15.831804+00:00 2023-02-25T12:18:19.761722+00:00 0:00:03.929918 345283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-25T12:18:13.210763+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-25T10:00:00+00:00 TriggerDagRunOperator 2023-02-25T11:16:41.585542+00:00 2023-02-25T11:16:42.097230+00:00 0:00:00.511688 345277 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T11:16:38.959128+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-25T10:00:00+00:00 TriggerDagRunOperator 2023-02-25T11:16:41.345896+00:00 2023-02-25T11:16:41.875629+00:00 0:00:00.529733 345276 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-25T11:16:38.959100+00:00 2 default_pool