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-08T21:00:00+00:00 EmrJobFlowSensor 2023-02-08T22:00:53.279547+00:00 2023-02-08T22:10:55.117406+00:00 0:10:01.837859 336162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T22:00:50.966907+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T22:00:32.645346+00:00 2023-02-08T22:00:33.795873+00:00 0:00:01.150527 336160 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T22:00:29.007158+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T21:00:00+00:00 PythonOperator 2023-02-08T22:00:11.342747+00:00 2023-02-08T22:00:14.240855+00:00 0:00:02.898108 336158 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T22:00:08.930679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T20:00:00+00:00 TriggerDagRunOperator 2023-02-08T21:11:20.900859+00:00 2023-02-08T21:11:21.471271+00:00 0:00:00.570412 336144 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T21:11:18.203333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T20:00:00+00:00 TriggerDagRunOperator 2023-02-08T21:11:20.737132+00:00 2023-02-08T21:11:21.249135+00:00 0:00:00.512003 336143 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T21:11:18.203304+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T20:00:00+00:00 EmrJobFlowSensor 2023-02-08T21:01:07.081153+00:00 2023-02-08T21:11:08.793792+00:00 0:10:01.712639 336136 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T21:01:04.712850+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T21:00:44.865582+00:00 2023-02-08T21:00:45.769782+00:00 0:00:00.904200 336134 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T21:00:42.628369+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T20:00:00+00:00 PythonOperator 2023-02-08T21:00:22.744223+00:00 2023-02-08T21:00:26.612902+00:00 0:00:03.868679 336132 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T21:00:20.542654+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T19:00:00+00:00 TriggerDagRunOperator 2023-02-08T20:11:21.739306+00:00 2023-02-08T20:11:22.266214+00:00 0:00:00.526908 336118 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T20:11:18.918993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T19:00:00+00:00 TriggerDagRunOperator 2023-02-08T20:11:21.519428+00:00 2023-02-08T20:11:21.989571+00:00 0:00:00.470143 336117 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T20:11:18.918924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T19:00:00+00:00 EmrJobFlowSensor 2023-02-08T20:00:59.699890+00:00 2023-02-08T20:11:01.831047+00:00 0:10:02.131157 336109 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T20:00:57.111586+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T20:00:39.468158+00:00 2023-02-08T20:00:40.306189+00:00 0:00:00.838031 336107 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T20:00:37.035359+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T19:00:00+00:00 PythonOperator 2023-02-08T20:00:15.318093+00:00 2023-02-08T20:00:19.195456+00:00 0:00:03.877363 336105 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T20:00:12.987172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T18:00:00+00:00 TriggerDagRunOperator 2023-02-08T19:11:10.976920+00:00 2023-02-08T19:11:11.521285+00:00 0:00:00.544365 336092 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T19:11:08.573734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T18:00:00+00:00 TriggerDagRunOperator 2023-02-08T19:11:10.934151+00:00 2023-02-08T19:11:11.463913+00:00 0:00:00.529762 336091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T19:11:08.573764+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T18:00:00+00:00 EmrJobFlowSensor 2023-02-08T19:00:56.571604+00:00 2023-02-08T19:10:58.217748+00:00 0:10:01.646144 336083 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T19:00:54.351336+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T19:00:38.409064+00:00 2023-02-08T19:00:39.642411+00:00 0:00:01.233347 336082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T19:00:34.339157+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T18:00:00+00:00 PythonOperator 2023-02-08T19:00:14.991546+00:00 2023-02-08T19:00:17.909949+00:00 0:00:02.918403 336080 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T19:00:12.314235+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T17:00:00+00:00 TriggerDagRunOperator 2023-02-08T18:12:59.366641+00:00 2023-02-08T18:12:59.852780+00:00 0:00:00.486139 336066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T18:12:56.521504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T17:00:00+00:00 TriggerDagRunOperator 2023-02-08T18:12:59.122060+00:00 2023-02-08T18:12:59.595545+00:00 0:00:00.473485 336065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T18:12:56.521475+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T17:00:00+00:00 EmrJobFlowSensor 2023-02-08T18:02:47.739923+00:00 2023-02-08T18:12:49.573894+00:00 0:10:01.833971 336059 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T18:02:44.535448+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T18:02:24.726689+00:00 2023-02-08T18:02:25.634802+00:00 0:00:00.908113 336057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T18:02:22.476342+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T17:00:00+00:00 PythonOperator 2023-02-08T18:02:05.111619+00:00 2023-02-08T18:02:08.902928+00:00 0:00:03.791309 336055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T18:02:02.459937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T16:00:00+00:00 TriggerDagRunOperator 2023-02-08T17:15:05.029985+00:00 2023-02-08T17:15:05.539552+00:00 0:00:00.509567 336041 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T17:15:02.446557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T16:00:00+00:00 TriggerDagRunOperator 2023-02-08T17:15:04.813281+00:00 2023-02-08T17:15:05.296773+00:00 0:00:00.483492 336040 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T17:15:02.446528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T16:00:00+00:00 EmrJobFlowSensor 2023-02-08T17:04:46.500226+00:00 2023-02-08T17:14:48.272745+00:00 0:10:01.772519 336033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T17:04:44.234852+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T17:04:26.627422+00:00 2023-02-08T17:04:27.460445+00:00 0:00:00.833023 336031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T17:04:24.206793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T16:00:00+00:00 PythonOperator 2023-02-08T17:04:05.082605+00:00 2023-02-08T17:04:08.113193+00:00 0:00:03.030588 336029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T17:04:02.242049+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T15:00:00+00:00 TriggerDagRunOperator 2023-02-08T16:22:39.644613+00:00 2023-02-08T16:22:40.143165+00:00 0:00:00.498552 336017 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T16:22:37.206695+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T15:00:00+00:00 TriggerDagRunOperator 2023-02-08T16:22:39.615188+00:00 2023-02-08T16:22:40.125012+00:00 0:00:00.509824 336016 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T16:22:37.206723+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T15:00:00+00:00 EmrJobFlowSensor 2023-02-08T16:00:58.897487+00:00 2023-02-08T16:11:00.845875+00:00 0:10:01.948388 336008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T16:00:56.569820+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T16:00:37.181168+00:00 2023-02-08T16:00:38.153514+00:00 0:00:00.972346 336006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T16:00:34.612111+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T15:00:00+00:00 PythonOperator 2023-02-08T16:00:15.359274+00:00 2023-02-08T16:00:21.353533+00:00 0:00:05.994259 336004 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T16:00:12.595376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T14:00:00+00:00 TriggerDagRunOperator 2023-02-08T15:23:43.564935+00:00 2023-02-08T15:23:44.094433+00:00 0:00:00.529498 335993 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T15:23:41.133910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T14:00:00+00:00 TriggerDagRunOperator 2023-02-08T15:23:43.510551+00:00 2023-02-08T15:23:44.007096+00:00 0:00:00.496545 335992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T15:23:41.133880+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T14:00:00+00:00 EmrJobFlowSensor 2023-02-08T15:13:33.772604+00:00 2023-02-08T15:23:35.594255+00:00 0:10:01.821651 335988 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T15:13:31.305251+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T15:13:13.399241+00:00 2023-02-08T15:13:14.268467+00:00 0:00:00.869226 335985 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T15:13:11.213653+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T14:00:00+00:00 PythonOperator 2023-02-08T15:12:54.004486+00:00 2023-02-08T15:12:57.191588+00:00 0:00:03.187102 335982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T15:12:49.203636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T13:00:00+00:00 TriggerDagRunOperator 2023-02-08T14:34:21.686336+00:00 2023-02-08T14:34:22.196393+00:00 0:00:00.510057 335970 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T14:34:19.247422+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T13:00:00+00:00 TriggerDagRunOperator 2023-02-08T14:34:21.637788+00:00 2023-02-08T14:34:22.121013+00:00 0:00:00.483225 335969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T14:34:19.247452+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T13:00:00+00:00 EmrJobFlowSensor 2023-02-08T14:24:07.439042+00:00 2023-02-08T14:34:09.366808+00:00 0:10:01.927766 335966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T14:24:03.727298+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T14:23:44.065814+00:00 2023-02-08T14:23:44.953637+00:00 0:00:00.887823 335962 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T14:23:41.706427+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T13:00:00+00:00 PythonOperator 2023-02-08T14:23:24.021318+00:00 2023-02-08T14:23:27.857370+00:00 0:00:03.836052 335960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T14:23:21.725691+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T12:00:00+00:00 TriggerDagRunOperator 2023-02-08T13:33:53.101467+00:00 2023-02-08T13:33:53.756524+00:00 0:00:00.655057 335949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T13:33:50.094305+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T12:00:00+00:00 TriggerDagRunOperator 2023-02-08T13:33:52.916645+00:00 2023-02-08T13:33:53.398135+00:00 0:00:00.481490 335948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T13:33:50.094271+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T12:00:00+00:00 EmrJobFlowSensor 2023-02-08T13:02:16.521911+00:00 2023-02-08T13:12:18.865005+00:00 0:10:02.343094 335941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T13:02:14.230633+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T13:01:56.708291+00:00 2023-02-08T13:01:58.010331+00:00 0:00:01.302040 335939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T13:01:54.213514+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T12:00:00+00:00 PythonOperator 2023-02-08T13:01:34.951409+00:00 2023-02-08T13:01:37.895373+00:00 0:00:02.943964 335937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T13:01:32.193191+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T11:00:00+00:00 TriggerDagRunOperator 2023-02-08T12:12:40.210301+00:00 2023-02-08T12:12:40.726848+00:00 0:00:00.516547 335926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T12:12:37.726278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T11:00:00+00:00 TriggerDagRunOperator 2023-02-08T12:12:40.167049+00:00 2023-02-08T12:12:40.700156+00:00 0:00:00.533107 335925 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T12:12:37.726306+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T11:00:00+00:00 EmrJobFlowSensor 2023-02-08T12:02:24.197080+00:00 2023-02-08T12:12:26.076952+00:00 0:10:01.879872 335919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T12:02:21.787522+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T12:02:04.115097+00:00 2023-02-08T12:02:04.949877+00:00 0:00:00.834780 335917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T12:02:01.761806+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T11:00:00+00:00 PythonOperator 2023-02-08T12:01:41.979314+00:00 2023-02-08T12:01:45.753106+00:00 0:00:03.773792 335915 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T12:01:39.740505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T10:00:00+00:00 TriggerDagRunOperator 2023-02-08T11:11:16.103802+00:00 2023-02-08T11:11:16.603457+00:00 0:00:00.499655 335902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T11:11:13.845267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T10:00:00+00:00 TriggerDagRunOperator 2023-02-08T11:11:16.073896+00:00 2023-02-08T11:11:16.546561+00:00 0:00:00.472665 335901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T11:11:13.845239+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T10:00:00+00:00 EmrJobFlowSensor 2023-02-08T11:00:56.652406+00:00 2023-02-08T11:10:58.487221+00:00 0:10:01.834815 335892 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T11:00:54.202191+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T11:00:34.645851+00:00 2023-02-08T11:00:35.480933+00:00 0:00:00.835082 335891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T11:00:32.191071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T10:00:00+00:00 PythonOperator 2023-02-08T11:00:12.732765+00:00 2023-02-08T11:00:15.592669+00:00 0:00:02.859904 335890 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T11:00:10.192667+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T09:00:00+00:00 TriggerDagRunOperator 2023-02-08T10:11:26.838649+00:00 2023-02-08T10:11:27.382151+00:00 0:00:00.543502 335876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T10:11:24.620558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T09:00:00+00:00 TriggerDagRunOperator 2023-02-08T10:11:26.851541+00:00 2023-02-08T10:11:27.318721+00:00 0:00:00.467180 335875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T10:11:24.620592+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T09:00:00+00:00 EmrJobFlowSensor 2023-02-08T10:01:06.092759+00:00 2023-02-08T10:11:07.970216+00:00 0:10:01.877457 335869 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T10:01:03.505751+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T10:00:43.731871+00:00 2023-02-08T10:00:44.756990+00:00 0:00:01.025119 335867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T10:00:41.488296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T09:00:00+00:00 PythonOperator 2023-02-08T10:00:23.739904+00:00 2023-02-08T10:00:26.540910+00:00 0:00:02.801006 335865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T10:00:21.467163+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T08:00:00+00:00 TriggerDagRunOperator 2023-02-08T09:13:58.534176+00:00 2023-02-08T09:13:59.063884+00:00 0:00:00.529708 335851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T09:13:55.716147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T08:00:00+00:00 TriggerDagRunOperator 2023-02-08T09:13:58.416185+00:00 2023-02-08T09:13:58.882481+00:00 0:00:00.466296 335850 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T09:13:55.716119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T08:00:00+00:00 EmrJobFlowSensor 2023-02-08T09:03:40.973212+00:00 2023-02-08T09:13:42.809578+00:00 0:10:01.836366 335844 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T09:03:38.802001+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T09:03:21.033630+00:00 2023-02-08T09:03:22.002671+00:00 0:00:00.969041 335842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T09:03:18.802985+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T08:00:00+00:00 PythonOperator 2023-02-08T09:02:59.316186+00:00 2023-02-08T09:03:03.139450+00:00 0:00:03.823264 335840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T09:02:56.764127+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T07:00:00+00:00 TriggerDagRunOperator 2023-02-08T08:14:34.144655+00:00 2023-02-08T08:14:34.707189+00:00 0:00:00.562534 335826 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T08:14:31.027431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T07:00:00+00:00 TriggerDagRunOperator 2023-02-08T08:14:34.000543+00:00 2023-02-08T08:14:34.517394+00:00 0:00:00.516851 335825 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T08:14:31.027393+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T07:00:00+00:00 EmrJobFlowSensor 2023-02-08T08:01:41.672187+00:00 2023-02-08T08:11:43.456031+00:00 0:10:01.783844 335818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T08:01:39.341075+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T08:01:19.735121+00:00 2023-02-08T08:01:20.870488+00:00 0:00:01.135367 335816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T08:01:17.297910+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T07:00:00+00:00 PythonOperator 2023-02-08T08:01:01.191696+00:00 2023-02-08T08:01:05.738446+00:00 0:00:04.546750 335814 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T08:00:57.312448+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T06:00:00+00:00 TriggerDagRunOperator 2023-02-08T07:15:38.921912+00:00 2023-02-08T07:15:39.437186+00:00 0:00:00.515274 335802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T07:15:36.544956+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T06:00:00+00:00 TriggerDagRunOperator 2023-02-08T07:15:38.911905+00:00 2023-02-08T07:15:39.435448+00:00 0:00:00.523543 335801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T07:15:36.544927+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T06:00:00+00:00 EmrJobFlowSensor 2023-02-08T07:05:15.610404+00:00 2023-02-08T07:15:17.988812+00:00 0:10:02.378408 335795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T07:05:10.630864+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T07:04:52.795556+00:00 2023-02-08T07:04:53.644680+00:00 0:00:00.849124 335792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T07:04:50.586560+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T06:00:00+00:00 PythonOperator 2023-02-08T07:04:31.285830+00:00 2023-02-08T07:04:34.495224+00:00 0:00:03.209394 335790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T07:04:28.565598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T05:00:00+00:00 TriggerDagRunOperator 2023-02-08T06:11:31.130631+00:00 2023-02-08T06:11:31.701130+00:00 0:00:00.570499 335776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T06:11:28.662349+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T05:00:00+00:00 TriggerDagRunOperator 2023-02-08T06:11:31.043127+00:00 2023-02-08T06:11:31.637099+00:00 0:00:00.593972 335775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T06:11:28.662319+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T05:00:00+00:00 EmrJobFlowSensor 2023-02-08T06:01:06.135236+00:00 2023-02-08T06:11:08.077434+00:00 0:10:01.942198 335769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T06:01:03.496492+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T06:00:43.749247+00:00 2023-02-08T06:00:44.617203+00:00 0:00:00.867956 335767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T06:00:41.345364+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T05:00:00+00:00 PythonOperator 2023-02-08T06:00:23.679339+00:00 2023-02-08T06:00:27.467530+00:00 0:00:03.788191 335765 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T06:00:21.403013+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T04:00:00+00:00 TriggerDagRunOperator 2023-02-08T05:10:43.357921+00:00 2023-02-08T05:10:43.880657+00:00 0:00:00.522736 335752 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T05:10:40.403623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T04:00:00+00:00 TriggerDagRunOperator 2023-02-08T05:10:43.301066+00:00 2023-02-08T05:10:43.781030+00:00 0:00:00.479964 335751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T05:10:40.403594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T04:00:00+00:00 EmrJobFlowSensor 2023-02-08T05:01:31.983052+00:00 2023-02-08T05:10:33.547741+00:00 0:09:01.564689 335744 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T05:01:29.633470+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T05:00:27.591718+00:00 2023-02-08T05:00:28.428127+00:00 0:00:00.836409 335741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T05:00:25.349969+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T04:00:00+00:00 PythonOperator 2023-02-08T05:00:06.141418+00:00 2023-02-08T05:00:09.233909+00:00 0:00:03.092491 335739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T05:00:03.401478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T03:00:00+00:00 TriggerDagRunOperator 2023-02-08T04:12:10.549015+00:00 2023-02-08T04:12:11.123860+00:00 0:00:00.574845 335726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T04:12:07.585259+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T03:00:00+00:00 TriggerDagRunOperator 2023-02-08T04:12:10.444352+00:00 2023-02-08T04:12:10.924162+00:00 0:00:00.479810 335725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T04:12:07.585287+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T03:00:00+00:00 EmrJobFlowSensor 2023-02-08T04:02:03.478711+00:00 2023-02-08T04:12:05.244763+00:00 0:10:01.766052 335720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T04:02:01.130002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T04:01:43.335362+00:00 2023-02-08T04:01:44.227714+00:00 0:00:00.892352 335718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T04:01:41.110313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T03:00:00+00:00 PythonOperator 2023-02-08T04:00:16.835114+00:00 2023-02-08T04:00:20.574680+00:00 0:00:03.739566 335714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T04:00:14.631802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T02:00:00+00:00 TriggerDagRunOperator 2023-02-08T03:12:31.330239+00:00 2023-02-08T03:12:31.843251+00:00 0:00:00.513012 335703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T03:12:28.727288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T02:00:00+00:00 TriggerDagRunOperator 2023-02-08T03:12:31.229568+00:00 2023-02-08T03:12:31.728206+00:00 0:00:00.498638 335702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T03:12:28.727259+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-08T02:00:00+00:00 EmrJobFlowSensor 2023-02-08T03:02:09.643092+00:00 2023-02-08T03:12:11.371816+00:00 0:10:01.728724 335695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-08T03:02:07.206249+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-08T03:01:47.635133+00:00 2023-02-08T03:01:48.752919+00:00 0:00:01.117786 335693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-08T03:01:45.188084+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-08T02:00:00+00:00 PythonOperator 2023-02-08T03:01:27.831752+00:00 2023-02-08T03:01:31.153639+00:00 0:00:03.321887 335691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-08T03:01:25.142055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-08T01:00:00+00:00 TriggerDagRunOperator 2023-02-08T02:11:04.430388+00:00 2023-02-08T02:11:04.906303+00:00 0:00:00.475915 335679 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T02:11:01.513146+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-08T01:00:00+00:00 TriggerDagRunOperator 2023-02-08T02:11:04.092290+00:00 2023-02-08T02:11:04.656672+00:00 0:00:00.564382 335678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-08T02:11:01.513112+00:00 2 default_pool