Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2023-03-10T15:00:00+00:00 EmrJobFlowSensor 2023-03-10T16:03:29.011736+00:00 2023-03-10T16:13:30.848591+00:00 0:10:01.836855 351425 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T16:03:26.626473+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T16:03:06.771953+00:00 2023-03-10T16:03:07.571328+00:00 0:00:00.799375 351423 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T16:03:04.604383+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T15:00:00+00:00 PythonOperator 2023-03-10T16:02:47.540004+00:00 2023-03-10T16:02:50.859956+00:00 0:00:03.319952 351421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T16:02:44.600481+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T14:00:00+00:00 TriggerDagRunOperator 2023-03-10T15:16:55.261789+00:00 2023-03-10T15:16:55.733937+00:00 0:00:00.472148 351412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T15:16:52.706784+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T14:00:00+00:00 TriggerDagRunOperator 2023-03-10T15:16:55.023309+00:00 2023-03-10T15:16:55.546999+00:00 0:00:00.523690 351411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T15:16:52.706814+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T14:00:00+00:00 EmrJobFlowSensor 2023-03-10T15:06:41.152613+00:00 2023-03-10T15:16:42.847428+00:00 0:10:01.694815 351407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T15:06:38.827866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T15:06:21.209724+00:00 2023-03-10T15:06:22.103995+00:00 0:00:00.894271 351404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T15:06:18.796671+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T14:00:00+00:00 PythonOperator 2023-03-10T15:05:59.164931+00:00 2023-03-10T15:06:05.363361+00:00 0:00:06.198430 351401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T15:05:56.777546+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T13:00:00+00:00 TriggerDagRunOperator 2023-03-10T14:30:34.884726+00:00 2023-03-10T14:30:35.468326+00:00 0:00:00.583600 351392 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T14:30:32.051268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T13:00:00+00:00 TriggerDagRunOperator 2023-03-10T14:30:34.610450+00:00 2023-03-10T14:30:35.255222+00:00 0:00:00.644772 351391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T14:30:32.051295+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T13:00:00+00:00 EmrJobFlowSensor 2023-03-10T14:06:13.542655+00:00 2023-03-10T14:16:15.430304+00:00 0:10:01.887649 351387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T14:06:10.908546+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T14:05:51.205701+00:00 2023-03-10T14:05:52.047621+00:00 0:00:00.841920 351384 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T14:05:48.830110+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T13:00:00+00:00 PythonOperator 2023-03-10T14:05:28.978907+00:00 2023-03-10T14:05:32.945071+00:00 0:00:03.966164 351381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T14:05:26.768153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T12:00:00+00:00 TriggerDagRunOperator 2023-03-10T13:38:35.302082+00:00 2023-03-10T13:38:35.813460+00:00 0:00:00.511378 351374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T13:38:32.339558+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T12:00:00+00:00 TriggerDagRunOperator 2023-03-10T13:38:35.083709+00:00 2023-03-10T13:38:35.596830+00:00 0:00:00.513121 351373 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T13:38:32.339528+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T12:00:00+00:00 EmrJobFlowSensor 2023-03-10T13:01:44.264382+00:00 2023-03-10T13:11:46.334286+00:00 0:10:02.069904 351367 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T13:01:41.095649+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T13:01:21.449736+00:00 2023-03-10T13:01:22.510902+00:00 0:00:01.061166 351365 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T13:01:19.078799+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T12:00:00+00:00 PythonOperator 2023-03-10T13:01:01.914165+00:00 2023-03-10T13:01:05.206447+00:00 0:00:03.292282 351363 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T13:00:59.058195+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T11:00:00+00:00 TriggerDagRunOperator 2023-03-10T12:11:04.000827+00:00 2023-03-10T12:11:04.487139+00:00 0:00:00.486312 351353 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T12:11:01.217508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T11:00:00+00:00 TriggerDagRunOperator 2023-03-10T12:11:03.742624+00:00 2023-03-10T12:11:04.215978+00:00 0:00:00.473354 351352 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T12:11:01.217461+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T11:00:00+00:00 EmrJobFlowSensor 2023-03-10T12:00:49.589656+00:00 2023-03-10T12:10:51.352689+00:00 0:10:01.763033 351345 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T12:00:47.390386+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T12:00:29.548936+00:00 2023-03-10T12:00:30.351027+00:00 0:00:00.802091 351343 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T12:00:27.336902+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T11:00:00+00:00 PythonOperator 2023-03-10T12:00:06.079630+00:00 2023-03-10T12:00:10.050161+00:00 0:00:03.970531 351341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T12:00:03.390775+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T10:00:00+00:00 TriggerDagRunOperator 2023-03-10T11:11:23.526999+00:00 2023-03-10T11:11:24.055181+00:00 0:00:00.528182 351331 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T11:11:20.290415+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T10:00:00+00:00 TriggerDagRunOperator 2023-03-10T11:11:23.193508+00:00 2023-03-10T11:11:23.649381+00:00 0:00:00.455873 351330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T11:11:20.290446+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T10:00:00+00:00 EmrJobFlowSensor 2023-03-10T11:01:06.309537+00:00 2023-03-10T11:11:08.156900+00:00 0:10:01.847363 351324 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T11:01:03.897280+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T11:00:44.529362+00:00 2023-03-10T11:00:45.466079+00:00 0:00:00.936717 351322 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T11:00:41.894296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T10:00:00+00:00 PythonOperator 2023-03-10T11:00:22.137669+00:00 2023-03-10T11:00:26.188362+00:00 0:00:04.050693 351320 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T11:00:19.759588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T09:00:00+00:00 TriggerDagRunOperator 2023-03-10T10:21:51.686516+00:00 2023-03-10T10:21:52.205152+00:00 0:00:00.518636 351310 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T10:21:48.871077+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T09:00:00+00:00 TriggerDagRunOperator 2023-03-10T10:21:51.477294+00:00 2023-03-10T10:21:52.017348+00:00 0:00:00.540054 351309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T10:21:48.871105+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T09:00:00+00:00 EmrJobFlowSensor 2023-03-10T10:01:05.517392+00:00 2023-03-10T10:11:07.327306+00:00 0:10:01.809914 351302 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T10:01:03.308468+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T10:00:43.641248+00:00 2023-03-10T10:00:44.921815+00:00 0:00:01.280567 351300 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T10:00:41.285322+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T09:00:00+00:00 PythonOperator 2023-03-10T10:00:23.563961+00:00 2023-03-10T10:00:27.575391+00:00 0:00:04.011430 351298 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T10:00:21.268550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T08:00:00+00:00 TriggerDagRunOperator 2023-03-10T09:11:22.734560+00:00 2023-03-10T09:11:23.201109+00:00 0:00:00.466549 351290 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T09:11:20.119993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T08:00:00+00:00 TriggerDagRunOperator 2023-03-10T09:11:22.614965+00:00 2023-03-10T09:11:23.078601+00:00 0:00:00.463636 351289 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T09:11:20.119965+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T08:00:00+00:00 EmrJobFlowSensor 2023-03-10T09:01:06.754488+00:00 2023-03-10T09:11:08.495838+00:00 0:10:01.741350 351283 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T09:01:04.522446+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T09:00:46.668413+00:00 2023-03-10T09:00:47.507267+00:00 0:00:00.838854 351281 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T09:00:44.487539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T08:00:00+00:00 PythonOperator 2023-03-10T09:00:25.124433+00:00 2023-03-10T09:00:28.415422+00:00 0:00:03.290989 351279 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T09:00:22.424730+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T07:00:00+00:00 TriggerDagRunOperator 2023-03-10T08:12:26.893091+00:00 2023-03-10T08:12:27.432086+00:00 0:00:00.538995 351268 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T08:12:24.516677+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T07:00:00+00:00 TriggerDagRunOperator 2023-03-10T08:12:26.826821+00:00 2023-03-10T08:12:27.299291+00:00 0:00:00.472470 351267 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T08:12:24.516705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T07:00:00+00:00 EmrJobFlowSensor 2023-03-10T08:02:20.487156+00:00 2023-03-10T08:12:22.229682+00:00 0:10:01.742526 351261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T08:02:17.734346+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T08:01:58.338514+00:00 2023-03-10T08:01:59.209970+00:00 0:00:00.871456 351259 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T08:01:55.687712+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T07:00:00+00:00 PythonOperator 2023-03-10T08:00:17.189220+00:00 2023-03-10T08:00:20.257981+00:00 0:00:03.068761 351255 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T08:00:14.697994+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T06:00:00+00:00 TriggerDagRunOperator 2023-03-10T07:11:49.828177+00:00 2023-03-10T07:11:50.343645+00:00 0:00:00.515468 351246 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T07:11:47.436715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T06:00:00+00:00 TriggerDagRunOperator 2023-03-10T07:11:49.828148+00:00 2023-03-10T07:11:50.332395+00:00 0:00:00.504247 351245 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T07:11:47.436688+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T06:00:00+00:00 EmrJobFlowSensor 2023-03-10T07:00:55.778354+00:00 2023-03-10T07:10:57.701704+00:00 0:10:01.923350 351237 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T07:00:53.451060+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T07:00:33.639122+00:00 2023-03-10T07:00:34.898278+00:00 0:00:01.259156 351235 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T07:00:31.428377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T06:00:00+00:00 PythonOperator 2023-03-10T07:00:13.944739+00:00 2023-03-10T07:00:18.276490+00:00 0:00:04.331751 351233 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T07:00:11.396408+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T05:00:00+00:00 TriggerDagRunOperator 2023-03-10T06:11:14.520074+00:00 2023-03-10T06:11:15.238315+00:00 0:00:00.718241 351204 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T06:11:11.959016+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T05:00:00+00:00 TriggerDagRunOperator 2023-03-10T06:11:14.147052+00:00 2023-03-10T06:11:14.856425+00:00 0:00:00.709373 351203 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T06:11:11.959050+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T05:00:00+00:00 EmrJobFlowSensor 2023-03-10T06:00:51.271878+00:00 2023-03-10T06:10:53.113645+00:00 0:10:01.841767 351197 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T06:00:48.688421+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T06:00:27.734635+00:00 2023-03-10T06:00:29.243191+00:00 0:00:01.508556 351194 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T06:00:24.718998+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T05:00:00+00:00 PythonOperator 2023-03-10T06:00:05.612546+00:00 2023-03-10T06:00:11.039354+00:00 0:00:05.426808 351192 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T06:00:02.703240+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T04:00:00+00:00 TriggerDagRunOperator 2023-03-10T05:11:12.409698+00:00 2023-03-10T05:11:12.898088+00:00 0:00:00.488390 351181 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T05:11:10.074265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T04:00:00+00:00 TriggerDagRunOperator 2023-03-10T05:11:12.324173+00:00 2023-03-10T05:11:12.799831+00:00 0:00:00.475658 351180 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T05:11:10.074237+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T04:00:00+00:00 EmrJobFlowSensor 2023-03-10T05:00:52.451698+00:00 2023-03-10T05:10:54.336015+00:00 0:10:01.884317 351171 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T05:00:50.230325+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T05:00:30.722611+00:00 2023-03-10T05:00:31.559462+00:00 0:00:00.836851 351170 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T05:00:28.211780+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T04:00:00+00:00 PythonOperator 2023-03-10T05:00:09.046172+00:00 2023-03-10T05:00:12.212201+00:00 0:00:03.166029 351168 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T05:00:06.222600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T03:00:00+00:00 TriggerDagRunOperator 2023-03-10T04:11:15.720899+00:00 2023-03-10T04:11:16.260416+00:00 0:00:00.539517 351158 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T04:11:13.093192+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T03:00:00+00:00 TriggerDagRunOperator 2023-03-10T04:11:15.709595+00:00 2023-03-10T04:11:16.265608+00:00 0:00:00.556013 351157 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T04:11:13.093222+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T03:00:00+00:00 EmrJobFlowSensor 2023-03-10T04:01:03.247748+00:00 2023-03-10T04:11:05.049960+00:00 0:10:01.802212 351150 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T04:01:00.920938+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T04:00:43.320664+00:00 2023-03-10T04:00:44.680494+00:00 0:00:01.359830 351148 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T04:00:40.879412+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T03:00:00+00:00 PythonOperator 2023-03-10T04:00:21.221482+00:00 2023-03-10T04:00:25.203626+00:00 0:00:03.982144 351146 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T04:00:18.859780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T02:00:00+00:00 TriggerDagRunOperator 2023-03-10T03:12:22.088910+00:00 2023-03-10T03:12:22.632498+00:00 0:00:00.543588 351135 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T03:12:18.996030+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T02:00:00+00:00 TriggerDagRunOperator 2023-03-10T03:12:22.060511+00:00 2023-03-10T03:12:22.611126+00:00 0:00:00.550615 351134 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T03:12:18.995982+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T02:00:00+00:00 EmrJobFlowSensor 2023-03-10T03:01:59.190736+00:00 2023-03-10T03:12:00.985681+00:00 0:10:01.794945 351128 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T03:01:56.950150+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T03:01:37.089916+00:00 2023-03-10T03:01:37.894700+00:00 0:00:00.804784 351126 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T03:01:34.926083+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T02:00:00+00:00 PythonOperator 2023-03-10T03:01:15.292139+00:00 2023-03-10T03:01:18.697914+00:00 0:00:03.405775 351124 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T03:01:12.895621+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T01:00:00+00:00 TriggerDagRunOperator 2023-03-10T02:11:04.870850+00:00 2023-03-10T02:11:05.357206+00:00 0:00:00.486356 351111 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T02:11:02.287877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T01:00:00+00:00 TriggerDagRunOperator 2023-03-10T02:11:04.719448+00:00 2023-03-10T02:11:05.205151+00:00 0:00:00.485703 351110 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T02:11:02.287917+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T01:00:00+00:00 EmrJobFlowSensor 2023-03-10T02:00:52.210689+00:00 2023-03-10T02:10:54.124367+00:00 0:10:01.913678 351103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T02:00:49.803301+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T02:00:30.195320+00:00 2023-03-10T02:00:31.064017+00:00 0:00:00.868697 351101 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T02:00:27.757785+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T01:00:00+00:00 PythonOperator 2023-03-10T02:00:10.448726+00:00 2023-03-10T02:00:14.441064+00:00 0:00:03.992338 351099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T02:00:07.741225+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-10T00:00:00+00:00 TriggerDagRunOperator 2023-03-10T01:12:24.437215+00:00 2023-03-10T01:12:24.896605+00:00 0:00:00.459390 351082 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T01:12:21.777165+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-10T00:00:00+00:00 TriggerDagRunOperator 2023-03-10T01:12:24.315024+00:00 2023-03-10T01:12:24.799005+00:00 0:00:00.483981 351081 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T01:12:21.777137+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-10T00:00:00+00:00 EmrJobFlowSensor 2023-03-10T01:02:01.293265+00:00 2023-03-10T01:12:03.220677+00:00 0:10:01.927412 351074 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T01:01:59.003431+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-10T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T01:01:39.159170+00:00 2023-03-10T01:01:40.020582+00:00 0:00:00.861412 351072 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T01:01:36.942512+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-10T00:00:00+00:00 PythonOperator 2023-03-10T01:01:19.270880+00:00 2023-03-10T01:01:23.175922+00:00 0:00:03.905042 351070 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T01:01:16.919997+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T23:00:00+00:00 TriggerDagRunOperator 2023-03-10T00:11:19.381512+00:00 2023-03-10T00:11:19.902445+00:00 0:00:00.520933 351060 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T00:11:16.846601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T23:00:00+00:00 TriggerDagRunOperator 2023-03-10T00:11:19.259232+00:00 2023-03-10T00:11:19.724353+00:00 0:00:00.465121 351059 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-10T00:11:16.846573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T23:00:00+00:00 EmrJobFlowSensor 2023-03-10T00:00:56.352058+00:00 2023-03-10T00:10:58.262329+00:00 0:10:01.910271 351051 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-10T00:00:53.926717+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-10T00:00:34.471271+00:00 2023-03-10T00:00:35.412482+00:00 0:00:00.941211 351049 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-10T00:00:31.906932+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T23:00:00+00:00 PythonOperator 2023-03-10T00:00:14.520451+00:00 2023-03-10T00:00:17.742128+00:00 0:00:03.221677 351047 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-10T00:00:11.835772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T22:00:00+00:00 TriggerDagRunOperator 2023-03-09T23:11:17.217582+00:00 2023-03-09T23:11:17.694381+00:00 0:00:00.476799 351037 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T23:11:14.324363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T22:00:00+00:00 TriggerDagRunOperator 2023-03-09T23:11:17.069138+00:00 2023-03-09T23:11:17.530135+00:00 0:00:00.460997 351036 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T23:11:14.324392+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T22:00:00+00:00 EmrJobFlowSensor 2023-03-09T23:01:00.278922+00:00 2023-03-09T23:11:02.128290+00:00 0:10:01.849368 351028 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T23:00:57.893798+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T23:00:40.062428+00:00 2023-03-09T23:00:40.998504+00:00 0:00:00.936076 351025 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T23:00:37.796358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T22:00:00+00:00 PythonOperator 2023-03-09T23:00:17.900587+00:00 2023-03-09T23:00:23.867677+00:00 0:00:05.967090 351022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T23:00:15.705732+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T21:00:00+00:00 TriggerDagRunOperator 2023-03-09T22:11:05.488357+00:00 2023-03-09T22:11:06.032646+00:00 0:00:00.544289 351010 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T22:11:03.062161+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T21:00:00+00:00 TriggerDagRunOperator 2023-03-09T22:11:05.409799+00:00 2023-03-09T22:11:05.876664+00:00 0:00:00.466865 351009 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T22:11:03.062133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T21:00:00+00:00 EmrJobFlowSensor 2023-03-09T22:00:56.652141+00:00 2023-03-09T22:10:58.344650+00:00 0:10:01.692509 351001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T22:00:54.399911+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T22:00:34.550540+00:00 2023-03-09T22:00:35.358679+00:00 0:00:00.808139 350999 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T22:00:32.354752+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T21:00:00+00:00 PythonOperator 2023-03-09T22:00:12.663906+00:00 2023-03-09T22:00:15.813306+00:00 0:00:03.149400 350997 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T22:00:10.331859+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T20:00:00+00:00 TriggerDagRunOperator 2023-03-09T21:11:20.652818+00:00 2023-03-09T21:11:21.201437+00:00 0:00:00.548619 350987 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T21:11:17.598590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T20:00:00+00:00 TriggerDagRunOperator 2023-03-09T21:11:20.430999+00:00 2023-03-09T21:11:20.895445+00:00 0:00:00.464446 350986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T21:11:17.598634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-09T20:00:00+00:00 EmrJobFlowSensor 2023-03-09T21:01:06.756691+00:00 2023-03-09T21:11:08.620711+00:00 0:10:01.864020 350979 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-09T21:01:04.556402+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-09T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-09T21:00:46.826682+00:00 2023-03-09T21:00:47.991694+00:00 0:00:01.165012 350977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-09T21:00:42.536234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-09T20:00:00+00:00 PythonOperator 2023-03-09T21:00:24.734916+00:00 2023-03-09T21:00:27.917923+00:00 0:00:03.183007 350975 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-09T21:00:22.476844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-09T19:00:00+00:00 TriggerDagRunOperator 2023-03-09T20:11:18.984498+00:00 2023-03-09T20:11:19.491436+00:00 0:00:00.506938 350963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T20:11:16.144260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-09T19:00:00+00:00 TriggerDagRunOperator 2023-03-09T20:11:18.775022+00:00 2023-03-09T20:11:19.248933+00:00 0:00:00.473911 350962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-09T20:11:16.144232+00:00 2 default_pool