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 create_emr_steps 2021-04-10T13:00:00+00:00 PythonOperator 2021-04-10T14:00:10.957620+00:00 2021-04-10T14:00:13.903831+00:00 0:00:02.946211 15661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T14:00:08.789265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.692824+00:00 2021-04-10T13:10:47.193515+00:00 0:00:00.500691 15654 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T12:00:00+00:00 TriggerDagRunOperator 2021-04-10T13:10:46.536448+00:00 2021-04-10T13:10:46.963731+00:00 0:00:00.427283 15653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T13:10:44.163594+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T12:00:00+00:00 EmrJobFlowSensor 2021-04-10T13:02:25.862806+00:00 2021-04-10T13:10:28.405756+00:00 0:08:02.542950 15649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T13:02:23.259416+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T13:00:44.934079+00:00 2021-04-10T13:00:46.674296+00:00 0:00:01.740217 15647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T13:00:42.694469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T12:00:00+00:00 PythonOperator 2021-04-10T13:00:25.030808+00:00 2021-04-10T13:00:27.738911+00:00 0:00:02.708103 15646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T13:00:22.628841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T11:00:00+00:00 TriggerDagRunOperator 2021-04-10T12:12:00.235252+00:00 2021-04-10T12:12:00.829518+00:00 0:00:00.594266 15639 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:11:57.751379+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T11:00:00+00:00 TriggerDagRunOperator 2021-04-10T12:12:00.105737+00:00 2021-04-10T12:12:00.550969+00:00 0:00:00.445232 15638 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T12:11:57.751348+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T11:00:00+00:00 EmrJobFlowSensor 2021-04-10T12:01:39.028002+00:00 2021-04-10T12:11:41.744218+00:00 0:10:02.716216 15634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T12:01:36.886327+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T12:01:19.304098+00:00 2021-04-10T12:01:21.113667+00:00 0:00:01.809569 15633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T12:01:16.868671+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T11:00:00+00:00 PythonOperator 2021-04-10T12:00:19.825667+00:00 2021-04-10T12:00:22.697488+00:00 0:00:02.871821 15631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T12:00:17.359888+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:51.006556+00:00 2021-04-10T11:11:51.446509+00:00 0:00:00.439953 15624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T10:00:00+00:00 TriggerDagRunOperator 2021-04-10T11:11:50.860654+00:00 2021-04-10T11:11:51.388044+00:00 0:00:00.527390 15623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T11:11:48.366743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T10:00:00+00:00 EmrJobFlowSensor 2021-04-10T11:01:27.597398+00:00 2021-04-10T11:11:30.365183+00:00 0:10:02.767785 15619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T11:01:25.313672+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T11:01:07.539030+00:00 2021-04-10T11:01:09.380376+00:00 0:00:01.841346 15618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T11:01:05.296172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T10:00:00+00:00 PythonOperator 2021-04-10T11:00:45.956974+00:00 2021-04-10T11:00:48.838144+00:00 0:00:02.881170 15617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T11:00:43.284350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T09:00:00+00:00 TriggerDagRunOperator 2021-04-10T10:11:14.521293+00:00 2021-04-10T10:11:15.077761+00:00 0:00:00.556468 15609 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:11:11.997484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T09:00:00+00:00 TriggerDagRunOperator 2021-04-10T10:11:14.400501+00:00 2021-04-10T10:11:14.839311+00:00 0:00:00.438810 15608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T10:11:11.997447+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T09:00:00+00:00 EmrJobFlowSensor 2021-04-10T10:00:55.361737+00:00 2021-04-10T10:10:58.020733+00:00 0:10:02.658996 15604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T10:00:53.048525+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T10:00:33.320979+00:00 2021-04-10T10:00:35.455315+00:00 0:00:02.134336 15603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T10:00:31.034198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T09:00:00+00:00 PythonOperator 2021-04-10T10:00:13.700160+00:00 2021-04-10T10:00:16.539701+00:00 0:00:02.839541 15602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T10:00:11.069343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T08:00:00+00:00 TriggerDagRunOperator 2021-04-10T09:09:21.221572+00:00 2021-04-10T09:09:21.687677+00:00 0:00:00.466105 15592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:09:18.985421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T08:00:00+00:00 TriggerDagRunOperator 2021-04-10T09:09:21.209913+00:00 2021-04-10T09:09:21.833784+00:00 0:00:00.623871 15591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T09:09:18.985373+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T08:00:00+00:00 EmrJobFlowSensor 2021-04-10T09:01:00.748939+00:00 2021-04-10T09:09:03.400240+00:00 0:08:02.651301 15587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T09:00:58.064834+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T09:00:40.404390+00:00 2021-04-10T09:00:42.211483+00:00 0:00:01.807093 15586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T09:00:37.958533+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T08:00:00+00:00 PythonOperator 2021-04-10T09:00:18.359194+00:00 2021-04-10T09:00:21.203175+00:00 0:00:02.843981 15585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T09:00:15.891268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.369591+00:00 2021-04-10T08:11:33.964777+00:00 0:00:00.595186 15577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011511+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T07:00:00+00:00 TriggerDagRunOperator 2021-04-10T08:11:33.263617+00:00 2021-04-10T08:11:33.685596+00:00 0:00:00.421979 15576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T08:11:31.011542+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T07:00:00+00:00 EmrJobFlowSensor 2021-04-10T08:01:06.411954+00:00 2021-04-10T08:11:09.381907+00:00 0:10:02.969953 15572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T08:01:04.010216+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T08:00:44.225267+00:00 2021-04-10T08:00:45.933569+00:00 0:00:01.708302 15571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T08:00:41.942558+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T07:00:00+00:00 PythonOperator 2021-04-10T08:00:20.709938+00:00 2021-04-10T08:00:23.423850+00:00 0:00:02.713912 15570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T08:00:17.984418+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.857496+00:00 2021-04-10T07:09:01.476865+00:00 0:00:00.619369 15562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.066045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T06:00:00+00:00 TriggerDagRunOperator 2021-04-10T07:09:00.646272+00:00 2021-04-10T07:09:01.067880+00:00 0:00:00.421608 15561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T07:08:58.065999+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T06:00:00+00:00 EmrJobFlowSensor 2021-04-10T07:00:51.401953+00:00 2021-04-10T07:08:54.060017+00:00 0:08:02.658064 15557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T07:00:49.206219+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T07:00:29.423465+00:00 2021-04-10T07:00:31.147311+00:00 0:00:01.723846 15556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T07:00:27.157082+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T06:00:00+00:00 PythonOperator 2021-04-10T07:00:09.775057+00:00 2021-04-10T07:00:12.624379+00:00 0:00:02.849322 15555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T07:00:07.133706+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.830981+00:00 2021-04-10T06:10:00.362335+00:00 0:00:00.531354 15547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163089+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T05:00:00+00:00 TriggerDagRunOperator 2021-04-10T06:09:59.524187+00:00 2021-04-10T06:09:59.940236+00:00 0:00:00.416049 15546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T06:09:57.163048+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T05:00:00+00:00 EmrJobFlowSensor 2021-04-10T06:00:52.321989+00:00 2021-04-10T06:09:55.135472+00:00 0:09:02.813483 15542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T06:00:50.081321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T06:00:30.305038+00:00 2021-04-10T06:00:32.118912+00:00 0:00:01.813874 15541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T06:00:28.045303+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T05:00:00+00:00 PythonOperator 2021-04-10T06:00:10.487772+00:00 2021-04-10T06:00:13.369265+00:00 0:00:02.881493 15540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T06:00:08.013583+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.877547+00:00 2021-04-10T05:10:05.403497+00:00 0:00:00.525950 15532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813948+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T04:00:00+00:00 TriggerDagRunOperator 2021-04-10T05:10:04.619132+00:00 2021-04-10T05:10:05.046593+00:00 0:00:00.427461 15531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T05:10:01.813901+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T04:00:00+00:00 EmrJobFlowSensor 2021-04-10T05:00:56.823186+00:00 2021-04-10T05:09:59.361153+00:00 0:09:02.537967 15527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T05:00:54.696059+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T05:00:36.884667+00:00 2021-04-10T05:00:38.582393+00:00 0:00:01.697726 15526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T05:00:34.683375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T04:00:00+00:00 PythonOperator 2021-04-10T05:00:13.007419+00:00 2021-04-10T05:00:15.877605+00:00 0:00:02.870186 15525 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T05:00:10.617372+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.519765+00:00 2021-04-10T04:11:26.024661+00:00 0:00:00.504896 15517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T03:00:00+00:00 TriggerDagRunOperator 2021-04-10T04:11:25.278936+00:00 2021-04-10T04:11:25.700097+00:00 0:00:00.421161 15516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T04:11:22.486133+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T03:00:00+00:00 EmrJobFlowSensor 2021-04-10T04:01:01.752430+00:00 2021-04-10T04:11:04.513606+00:00 0:10:02.761176 15512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T04:00:59.511282+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T04:00:37.744702+00:00 2021-04-10T04:00:39.566996+00:00 0:00:01.822294 15511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T04:00:35.494713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T03:00:00+00:00 PythonOperator 2021-04-10T04:00:15.919052+00:00 2021-04-10T04:00:18.761409+00:00 0:00:02.842357 15510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T04:00:13.478051+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.142363+00:00 2021-04-10T03:10:02.774395+00:00 0:00:00.632032 15502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456246+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T02:00:00+00:00 TriggerDagRunOperator 2021-04-10T03:10:02.131194+00:00 2021-04-10T03:10:02.574626+00:00 0:00:00.443432 15501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T03:09:59.456197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T02:00:00+00:00 EmrJobFlowSensor 2021-04-10T03:00:54.675244+00:00 2021-04-10T03:09:57.335673+00:00 0:09:02.660429 15497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T03:00:52.301482+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T03:00:32.674202+00:00 2021-04-10T03:00:34.410324+00:00 0:00:01.736122 15496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T03:00:30.344993+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T02:00:00+00:00 PythonOperator 2021-04-10T03:00:10.539293+00:00 2021-04-10T03:00:13.227382+00:00 0:00:02.688089 15495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T03:00:08.232021+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.856916+00:00 2021-04-10T02:09:57.407887+00:00 0:00:00.550971 15487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.371970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T01:00:00+00:00 TriggerDagRunOperator 2021-04-10T02:09:56.609878+00:00 2021-04-10T02:09:57.033792+00:00 0:00:00.423914 15486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T02:09:54.372016+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T01:00:00+00:00 EmrJobFlowSensor 2021-04-10T02:00:47.785930+00:00 2021-04-10T02:09:50.607227+00:00 0:09:02.821297 15482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T02:00:45.461912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T02:00:25.706916+00:00 2021-04-10T02:00:27.591223+00:00 0:00:01.884307 15481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T02:00:23.389284+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T01:00:00+00:00 PythonOperator 2021-04-10T02:00:04.232363+00:00 2021-04-10T02:00:06.950717+00:00 0:00:02.718354 15480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T02:00:01.370390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-10T00:00:00+00:00 TriggerDagRunOperator 2021-04-10T01:10:07.419631+00:00 2021-04-10T01:10:07.975766+00:00 0:00:00.556135 15472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:04.457613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-10T00:00:00+00:00 TriggerDagRunOperator 2021-04-10T01:10:07.130910+00:00 2021-04-10T01:10:07.578512+00:00 0:00:00.447602 15471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T01:10:04.457666+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-10T00:00:00+00:00 EmrJobFlowSensor 2021-04-10T01:00:56.151354+00:00 2021-04-10T01:09:58.929941+00:00 0:09:02.778587 15467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T01:00:53.698910+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-10T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T01:00:33.912945+00:00 2021-04-10T01:00:35.607978+00:00 0:00:01.695033 15466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T01:00:31.646751+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-10T00:00:00+00:00 PythonOperator 2021-04-10T01:00:12.481484+00:00 2021-04-10T01:00:15.221018+00:00 0:00:02.739534 15465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T01:00:09.526639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T23:00:00+00:00 TriggerDagRunOperator 2021-04-10T00:09:29.131021+00:00 2021-04-10T00:09:29.664043+00:00 0:00:00.533022 15457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:09:26.670190+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T23:00:00+00:00 TriggerDagRunOperator 2021-04-10T00:09:28.891449+00:00 2021-04-10T00:09:29.307355+00:00 0:00:00.415906 15456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-10T00:09:26.670157+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T23:00:00+00:00 EmrJobFlowSensor 2021-04-10T00:01:06.232036+00:00 2021-04-10T00:09:08.735909+00:00 0:08:02.503873 15452 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-10T00:01:03.940829+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-10T00:00:44.008820+00:00 2021-04-10T00:00:45.691670+00:00 0:00:01.682850 15451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-10T00:00:41.796287+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T23:00:00+00:00 PythonOperator 2021-04-10T00:00:24.237936+00:00 2021-04-10T00:00:27.025864+00:00 0:00:02.787928 15450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-10T00:00:21.751504+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T22:00:00+00:00 TriggerDagRunOperator 2021-04-09T23:11:09.529185+00:00 2021-04-09T23:11:10.059115+00:00 0:00:00.529930 15442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:11:07.137160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T22:00:00+00:00 TriggerDagRunOperator 2021-04-09T23:11:09.472335+00:00 2021-04-09T23:11:09.903625+00:00 0:00:00.431290 15441 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T23:11:07.137128+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T22:00:00+00:00 EmrJobFlowSensor 2021-04-09T23:00:54.675106+00:00 2021-04-09T23:10:57.459066+00:00 0:10:02.783960 15437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T23:00:52.275849+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T23:00:32.535743+00:00 2021-04-09T23:00:34.227093+00:00 0:00:01.691350 15436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T23:00:30.248870+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T22:00:00+00:00 PythonOperator 2021-04-09T23:00:10.677877+00:00 2021-04-09T23:00:13.638772+00:00 0:00:02.960895 15435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T23:00:08.150358+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.429467+00:00 2021-04-09T22:11:12.874946+00:00 0:00:00.445479 15427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101843+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T21:00:00+00:00 TriggerDagRunOperator 2021-04-09T22:11:12.302508+00:00 2021-04-09T22:11:12.887775+00:00 0:00:00.585267 15426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T22:11:10.101811+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T21:00:00+00:00 EmrJobFlowSensor 2021-04-09T22:00:47.517995+00:00 2021-04-09T22:10:50.253941+00:00 0:10:02.735946 15422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T22:00:45.202721+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T22:00:27.483664+00:00 2021-04-09T22:00:29.318389+00:00 0:00:01.834725 15421 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T22:00:25.182384+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T21:00:00+00:00 PythonOperator 2021-04-09T22:00:05.688752+00:00 2021-04-09T22:00:09.210055+00:00 0:00:03.521303 15420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T22:00:03.162752+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.306732+00:00 2021-04-09T21:11:20.899998+00:00 0:00:00.593266 15412 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942584+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T20:00:00+00:00 TriggerDagRunOperator 2021-04-09T21:11:20.157970+00:00 2021-04-09T21:11:20.580037+00:00 0:00:00.422067 15411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T21:11:17.942551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T20:00:00+00:00 EmrJobFlowSensor 2021-04-09T21:00:59.255753+00:00 2021-04-09T21:11:02.057148+00:00 0:10:02.801395 15407 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T21:00:56.971900+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T21:00:39.331224+00:00 2021-04-09T21:00:41.137568+00:00 0:00:01.806344 15406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T21:00:36.896786+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T20:00:00+00:00 PythonOperator 2021-04-09T21:00:17.214445+00:00 2021-04-09T21:00:20.085058+00:00 0:00:02.870613 15405 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T21:00:14.823645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.997848+00:00 2021-04-09T20:10:16.562789+00:00 0:00:00.564941 15397 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T19:00:00+00:00 TriggerDagRunOperator 2021-04-09T20:10:15.789502+00:00 2021-04-09T20:10:16.191416+00:00 0:00:00.401914 15396 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T20:10:13.528535+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T19:00:00+00:00 EmrJobFlowSensor 2021-04-09T20:00:58.827933+00:00 2021-04-09T20:10:02.050418+00:00 0:09:03.222485 15392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T20:00:56.430716+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T20:00:32.585021+00:00 2021-04-09T20:00:34.330855+00:00 0:00:01.745834 15391 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T20:00:30.407010+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T19:00:00+00:00 PythonOperator 2021-04-09T20:00:10.831616+00:00 2021-04-09T20:00:13.707212+00:00 0:00:02.875596 15390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T20:00:08.456712+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:08.043985+00:00 2021-04-09T19:11:08.595848+00:00 0:00:00.551863 15382 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252131+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T18:00:00+00:00 TriggerDagRunOperator 2021-04-09T19:11:07.592814+00:00 2021-04-09T19:11:08.005447+00:00 0:00:00.412633 15381 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T19:11:05.252084+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T18:00:00+00:00 EmrJobFlowSensor 2021-04-09T19:00:54.569111+00:00 2021-04-09T19:10:57.723971+00:00 0:10:03.154860 15377 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T19:00:52.129415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T19:00:32.338728+00:00 2021-04-09T19:00:34.250695+00:00 0:00:01.911967 15376 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T19:00:30.113397+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-09T18:00:00+00:00 PythonOperator 2021-04-09T19:00:10.345114+00:00 2021-04-09T19:00:13.711243+00:00 0:00:03.366129 15375 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-09T19:00:08.096281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.290499+00:00 2021-04-09T18:11:57.844824+00:00 0:00:00.554325 15368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601827+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-09T17:00:00+00:00 TriggerDagRunOperator 2021-04-09T18:11:57.242479+00:00 2021-04-09T18:11:57.662614+00:00 0:00:00.420135 15367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-09T18:11:54.601855+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-09T17:00:00+00:00 EmrJobFlowSensor 2021-04-09T18:01:06.141053+00:00 2021-04-09T18:10:08.874939+00:00 0:09:02.733886 15362 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-09T18:01:03.793984+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-09T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-09T18:00:44.143045+00:00 2021-04-09T18:00:46.049083+00:00 0:00:01.906038 15361 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-09T18:00:41.721607+00:00 2 default_pool