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-05-14T17:00:00+00:00 PythonOperator 2021-05-14T18:01:50.108194+00:00 2021-05-14T18:01:53.270057+00:00 0:00:03.161863 28076 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T18:01:47.692129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T16:00:00+00:00 TriggerDagRunOperator 2021-05-14T17:10:09.570170+00:00 2021-05-14T17:10:10.109110+00:00 0:00:00.538940 28068 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:10:07.295934+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T16:00:00+00:00 TriggerDagRunOperator 2021-05-14T17:10:09.482651+00:00 2021-05-14T17:10:09.890990+00:00 0:00:00.408339 28067 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T17:10:07.295974+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T16:00:00+00:00 EmrJobFlowSensor 2021-05-14T17:00:54.814597+00:00 2021-05-14T17:09:57.670312+00:00 0:09:02.855715 28063 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T17:00:52.188840+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T16:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T17:00:32.562248+00:00 2021-05-14T17:00:34.311809+00:00 0:00:01.749561 28062 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T17:00:30.164782+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T16:00:00+00:00 PythonOperator 2021-05-14T17:00:10.823815+00:00 2021-05-14T17:00:13.982696+00:00 0:00:03.158881 28061 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T17:00:08.154819+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T15:00:00+00:00 TriggerDagRunOperator 2021-05-14T16:10:17.746639+00:00 2021-05-14T16:10:18.380581+00:00 0:00:00.633942 28053 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:10:15.182904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T15:00:00+00:00 TriggerDagRunOperator 2021-05-14T16:10:17.593690+00:00 2021-05-14T16:10:18.017303+00:00 0:00:00.423613 28052 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T16:10:15.182948+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T15:00:00+00:00 EmrJobFlowSensor 2021-05-14T16:01:00.496317+00:00 2021-05-14T16:10:03.358978+00:00 0:09:02.862661 28048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T16:00:58.152426+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T15:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T16:00:40.194403+00:00 2021-05-14T16:00:41.928401+00:00 0:00:01.733998 28047 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T16:00:38.045149+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T15:00:00+00:00 PythonOperator 2021-05-14T16:00:18.564570+00:00 2021-05-14T16:00:21.738406+00:00 0:00:03.173836 28046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T16:00:16.000227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T14:00:00+00:00 TriggerDagRunOperator 2021-05-14T15:11:13.922311+00:00 2021-05-14T15:11:14.459965+00:00 0:00:00.537654 28038 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:11:11.547887+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T14:00:00+00:00 TriggerDagRunOperator 2021-05-14T15:11:13.713675+00:00 2021-05-14T15:11:14.268956+00:00 0:00:00.555281 28037 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T15:11:11.547919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T14:00:00+00:00 EmrJobFlowSensor 2021-05-14T15:00:56.519073+00:00 2021-05-14T15:10:59.256111+00:00 0:10:02.737038 28033 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T15:00:54.285922+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T14:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T15:00:34.449246+00:00 2021-05-14T15:00:36.140154+00:00 0:00:01.690908 28032 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T15:00:32.245098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T14:00:00+00:00 PythonOperator 2021-05-14T15:00:12.604257+00:00 2021-05-14T15:00:15.808647+00:00 0:00:03.204390 28031 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T15:00:10.243958+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T13:00:00+00:00 TriggerDagRunOperator 2021-05-14T14:10:10.739733+00:00 2021-05-14T14:10:11.322329+00:00 0:00:00.582596 28023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:10:08.256601+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T13:00:00+00:00 TriggerDagRunOperator 2021-05-14T14:10:10.617806+00:00 2021-05-14T14:10:11.038592+00:00 0:00:00.420786 28022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T14:10:08.256634+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T13:00:00+00:00 EmrJobFlowSensor 2021-05-14T14:00:49.465105+00:00 2021-05-14T14:09:52.136694+00:00 0:09:02.671589 28018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T14:00:47.326014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T14:00:27.887738+00:00 2021-05-14T14:00:29.745257+00:00 0:00:01.857519 28017 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T14:00:25.355335+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T13:00:00+00:00 PythonOperator 2021-05-14T14:00:05.818538+00:00 2021-05-14T14:00:09.039680+00:00 0:00:03.221142 28016 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T14:00:03.363268+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T12:00:00+00:00 TriggerDagRunOperator 2021-05-14T13:12:28.637613+00:00 2021-05-14T13:12:29.157932+00:00 0:00:00.520319 28008 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:12:25.982267+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T12:00:00+00:00 TriggerDagRunOperator 2021-05-14T13:12:28.464723+00:00 2021-05-14T13:12:28.936148+00:00 0:00:00.471425 28007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T13:12:25.982233+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T12:00:00+00:00 EmrJobFlowSensor 2021-05-14T13:01:04.998612+00:00 2021-05-14T13:12:08.016943+00:00 0:11:03.018331 28003 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T13:01:02.783355+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T13:00:43.075404+00:00 2021-05-14T13:00:44.964160+00:00 0:00:01.888756 28002 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T13:00:40.720003+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T12:00:00+00:00 PythonOperator 2021-05-14T13:00:21.141124+00:00 2021-05-14T13:00:24.303923+00:00 0:00:03.162799 28001 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T13:00:18.703668+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T11:00:00+00:00 TriggerDagRunOperator 2021-05-14T12:11:04.650072+00:00 2021-05-14T12:11:05.058491+00:00 0:00:00.408419 27993 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:11:02.060368+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T11:00:00+00:00 TriggerDagRunOperator 2021-05-14T12:11:04.575713+00:00 2021-05-14T12:11:05.125401+00:00 0:00:00.549688 27992 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T12:11:02.060411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T11:00:00+00:00 EmrJobFlowSensor 2021-05-14T12:00:55.145353+00:00 2021-05-14T12:10:57.923768+00:00 0:10:02.778415 27988 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T12:00:52.691785+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T12:00:32.894593+00:00 2021-05-14T12:00:34.598615+00:00 0:00:01.704022 27987 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T12:00:30.663115+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T11:00:00+00:00 PythonOperator 2021-05-14T12:00:12.910869+00:00 2021-05-14T12:00:16.138576+00:00 0:00:03.227707 27986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T12:00:10.607623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T10:00:00+00:00 TriggerDagRunOperator 2021-05-14T11:09:04.411677+00:00 2021-05-14T11:09:04.936599+00:00 0:00:00.524922 27978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:02.071906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T10:00:00+00:00 TriggerDagRunOperator 2021-05-14T11:09:04.179677+00:00 2021-05-14T11:09:04.624766+00:00 0:00:00.445089 27977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T11:09:02.071875+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T10:00:00+00:00 EmrJobFlowSensor 2021-05-14T11:00:57.648602+00:00 2021-05-14T11:09:00.380692+00:00 0:08:02.732090 27973 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T11:00:55.389343+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T11:00:35.621991+00:00 2021-05-14T11:00:37.452708+00:00 0:00:01.830717 27972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T11:00:33.355323+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T10:00:00+00:00 PythonOperator 2021-05-14T11:00:13.751801+00:00 2021-05-14T11:00:16.887183+00:00 0:00:03.135382 27971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T11:00:11.333080+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T09:00:00+00:00 TriggerDagRunOperator 2021-05-14T10:10:03.486070+00:00 2021-05-14T10:10:04.185765+00:00 0:00:00.699695 27963 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:10:00.942324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T09:00:00+00:00 TriggerDagRunOperator 2021-05-14T10:10:03.296226+00:00 2021-05-14T10:10:03.730691+00:00 0:00:00.434465 27962 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T10:10:00.942273+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T09:00:00+00:00 EmrJobFlowSensor 2021-05-14T10:00:49.985524+00:00 2021-05-14T10:09:52.740509+00:00 0:09:02.754985 27958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T10:00:47.808192+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T10:00:28.413135+00:00 2021-05-14T10:00:30.283083+00:00 0:00:01.869948 27957 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T10:00:25.857365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T09:00:00+00:00 PythonOperator 2021-05-14T10:00:05.973405+00:00 2021-05-14T10:00:09.203652+00:00 0:00:03.230247 27956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T10:00:03.764644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T08:00:00+00:00 TriggerDagRunOperator 2021-05-14T09:13:23.621015+00:00 2021-05-14T09:13:24.215273+00:00 0:00:00.594258 27949 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:13:20.941361+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T08:00:00+00:00 TriggerDagRunOperator 2021-05-14T09:13:23.292802+00:00 2021-05-14T09:13:23.684426+00:00 0:00:00.391624 27948 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T09:13:20.941391+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T08:00:00+00:00 EmrJobFlowSensor 2021-05-14T09:00:52.731424+00:00 2021-05-14T09:12:55.963396+00:00 0:12:03.231972 27943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T09:00:50.430264+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T09:00:30.956962+00:00 2021-05-14T09:00:32.801771+00:00 0:00:01.844809 27942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T09:00:28.546143+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T08:00:00+00:00 PythonOperator 2021-05-14T09:00:08.581295+00:00 2021-05-14T09:00:11.789437+00:00 0:00:03.208142 27941 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T09:00:06.361598+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T07:00:00+00:00 TriggerDagRunOperator 2021-05-14T08:11:16.039131+00:00 2021-05-14T08:11:16.599810+00:00 0:00:00.560679 27933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:11:13.631749+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T07:00:00+00:00 TriggerDagRunOperator 2021-05-14T08:11:15.899822+00:00 2021-05-14T08:11:16.332793+00:00 0:00:00.432971 27932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T08:11:13.631706+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T07:00:00+00:00 EmrJobFlowSensor 2021-05-14T08:00:58.689816+00:00 2021-05-14T08:11:01.556759+00:00 0:10:02.866943 27928 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T08:00:56.599521+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T08:00:36.793585+00:00 2021-05-14T08:00:38.487858+00:00 0:00:01.694273 27927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T08:00:34.557936+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T07:00:00+00:00 PythonOperator 2021-05-14T08:00:14.664474+00:00 2021-05-14T08:00:17.814951+00:00 0:00:03.150477 27926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T08:00:12.483789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T06:00:00+00:00 TriggerDagRunOperator 2021-05-14T07:20:25.159743+00:00 2021-05-14T07:20:25.686201+00:00 0:00:00.526458 27919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:20:22.655792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T06:00:00+00:00 TriggerDagRunOperator 2021-05-14T07:20:24.975863+00:00 2021-05-14T07:20:25.442307+00:00 0:00:00.466444 27918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T07:20:22.655766+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T06:00:00+00:00 EmrJobFlowSensor 2021-05-14T07:01:00.710869+00:00 2021-05-14T07:20:05.080632+00:00 0:19:04.369763 27913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T07:00:58.262472+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T07:00:38.397420+00:00 2021-05-14T07:00:40.084251+00:00 0:00:01.686831 27912 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T07:00:36.197833+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T06:00:00+00:00 PythonOperator 2021-05-14T07:00:18.511401+00:00 2021-05-14T07:00:21.637976+00:00 0:00:03.126575 27911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T07:00:16.244772+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T05:00:00+00:00 TriggerDagRunOperator 2021-05-14T06:10:20.036330+00:00 2021-05-14T06:10:20.563824+00:00 0:00:00.527494 27904 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:10:17.260543+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T05:00:00+00:00 TriggerDagRunOperator 2021-05-14T06:10:19.784230+00:00 2021-05-14T06:10:20.200037+00:00 0:00:00.415807 27903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T06:10:17.260573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T05:00:00+00:00 EmrJobFlowSensor 2021-05-14T06:01:04.032995+00:00 2021-05-14T06:10:06.752136+00:00 0:09:02.719141 27898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T06:01:01.889552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T06:00:42.103289+00:00 2021-05-14T06:00:43.934040+00:00 0:00:01.830751 27897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T06:00:39.821339+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T05:00:00+00:00 PythonOperator 2021-05-14T06:00:19.976349+00:00 2021-05-14T06:00:23.117914+00:00 0:00:03.141565 27896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T06:00:17.802500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T04:00:00+00:00 TriggerDagRunOperator 2021-05-14T05:10:37.065982+00:00 2021-05-14T05:10:37.489326+00:00 0:00:00.423344 27889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:10:34.536140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T04:00:00+00:00 TriggerDagRunOperator 2021-05-14T05:10:36.992580+00:00 2021-05-14T05:10:37.559032+00:00 0:00:00.566452 27888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T05:10:34.536183+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T04:00:00+00:00 EmrJobFlowSensor 2021-05-14T05:01:10.385641+00:00 2021-05-14T05:10:13.076707+00:00 0:09:02.691066 27883 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T05:01:08.147120+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T05:00:44.566174+00:00 2021-05-14T05:00:46.396691+00:00 0:00:01.830517 27882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T05:00:42.147172+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T04:00:00+00:00 PythonOperator 2021-05-14T05:00:16.428413+00:00 2021-05-14T05:00:19.537510+00:00 0:00:03.109097 27881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T05:00:14.094090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T03:00:00+00:00 TriggerDagRunOperator 2021-05-14T04:10:27.350454+00:00 2021-05-14T04:10:27.888773+00:00 0:00:00.538319 27873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:10:24.843734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T03:00:00+00:00 TriggerDagRunOperator 2021-05-14T04:10:27.263073+00:00 2021-05-14T04:10:27.659180+00:00 0:00:00.396107 27872 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T04:10:24.843699+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T03:00:00+00:00 EmrJobFlowSensor 2021-05-14T04:01:03.517618+00:00 2021-05-14T04:10:06.342366+00:00 0:09:02.824748 27867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T04:01:00.732072+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T04:00:29.069071+00:00 2021-05-14T04:00:30.749080+00:00 0:00:01.680009 27866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T04:00:26.704399+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T03:00:00+00:00 PythonOperator 2021-05-14T04:00:06.925875+00:00 2021-05-14T04:00:10.115392+00:00 0:00:03.189517 27865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T04:00:04.683868+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T02:00:00+00:00 TriggerDagRunOperator 2021-05-14T03:08:59.651132+00:00 2021-05-14T03:09:00.188694+00:00 0:00:00.537562 27858 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:08:57.235393+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T02:00:00+00:00 TriggerDagRunOperator 2021-05-14T03:08:59.401409+00:00 2021-05-14T03:08:59.815213+00:00 0:00:00.413804 27857 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T03:08:57.235425+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T02:00:00+00:00 EmrJobFlowSensor 2021-05-14T03:01:51.097492+00:00 2021-05-14T03:08:53.688744+00:00 0:07:02.591252 27853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T03:01:48.656300+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T03:00:36.514998+00:00 2021-05-14T03:00:38.302042+00:00 0:00:01.787044 27851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T03:00:34.385419+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T02:00:00+00:00 PythonOperator 2021-05-14T03:00:14.902749+00:00 2021-05-14T03:00:17.986920+00:00 0:00:03.084171 27850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T03:00:12.378157+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T01:00:00+00:00 TriggerDagRunOperator 2021-05-14T02:14:16.125583+00:00 2021-05-14T02:14:16.640611+00:00 0:00:00.515028 27843 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:14:13.837488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T01:00:00+00:00 TriggerDagRunOperator 2021-05-14T02:14:16.052136+00:00 2021-05-14T02:14:16.440467+00:00 0:00:00.388331 27842 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T02:14:13.837520+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T01:00:00+00:00 EmrJobFlowSensor 2021-05-14T02:01:48.697535+00:00 2021-05-14T02:13:51.770744+00:00 0:12:03.073209 27838 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T02:01:46.353031+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T02:01:26.488835+00:00 2021-05-14T02:01:28.278324+00:00 0:00:01.789489 27837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T02:01:24.265246+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T01:00:00+00:00 PythonOperator 2021-05-14T02:01:06.549507+00:00 2021-05-14T02:01:09.637719+00:00 0:00:03.088212 27836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T02:01:04.187458+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-14T00:00:00+00:00 TriggerDagRunOperator 2021-05-14T01:13:36.011153+00:00 2021-05-14T01:13:36.531597+00:00 0:00:00.520444 27828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:13:33.692865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-14T00:00:00+00:00 TriggerDagRunOperator 2021-05-14T01:13:35.857189+00:00 2021-05-14T01:13:36.263588+00:00 0:00:00.406399 27827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T01:13:33.692840+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-14T00:00:00+00:00 EmrJobFlowSensor 2021-05-14T01:01:04.817419+00:00 2021-05-14T01:13:07.984158+00:00 0:12:03.166739 27823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T01:01:02.478670+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-14T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T01:00:42.665059+00:00 2021-05-14T01:00:44.505696+00:00 0:00:01.840637 27822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T01:00:40.391098+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-14T00:00:00+00:00 PythonOperator 2021-05-14T01:00:22.733231+00:00 2021-05-14T01:00:25.870751+00:00 0:00:03.137520 27821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T01:00:20.325793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T23:00:00+00:00 TriggerDagRunOperator 2021-05-14T00:11:08.745260+00:00 2021-05-14T00:11:09.306682+00:00 0:00:00.561422 27813 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:11:06.359342+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T23:00:00+00:00 TriggerDagRunOperator 2021-05-14T00:11:08.722154+00:00 2021-05-14T00:11:09.164578+00:00 0:00:00.442424 27812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-14T00:11:06.359294+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T23:00:00+00:00 EmrJobFlowSensor 2021-05-14T00:00:57.585333+00:00 2021-05-14T00:11:00.520880+00:00 0:10:02.935547 27808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-14T00:00:55.303026+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-14T00:00:37.574278+00:00 2021-05-14T00:00:39.409382+00:00 0:00:01.835104 27807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-14T00:00:35.284455+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T23:00:00+00:00 PythonOperator 2021-05-14T00:00:16.116026+00:00 2021-05-14T00:00:19.361246+00:00 0:00:03.245220 27806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-14T00:00:13.264741+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T22:00:00+00:00 TriggerDagRunOperator 2021-05-13T23:09:18.567551+00:00 2021-05-13T23:09:19.077794+00:00 0:00:00.510243 27798 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:09:16.198711+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T22:00:00+00:00 TriggerDagRunOperator 2021-05-13T23:09:18.430919+00:00 2021-05-13T23:09:18.860424+00:00 0:00:00.429505 27797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T23:09:16.198742+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T22:00:00+00:00 EmrJobFlowSensor 2021-05-13T23:00:55.761185+00:00 2021-05-13T23:08:58.582364+00:00 0:08:02.821179 27793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T23:00:53.439033+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T23:00:33.632146+00:00 2021-05-13T23:00:35.317579+00:00 0:00:01.685433 27791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T23:00:31.421338+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-13T22:00:00+00:00 PythonOperator 2021-05-13T23:00:12.305386+00:00 2021-05-13T23:00:15.606577+00:00 0:00:03.301191 27789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-13T23:00:09.467042+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-13T21:00:00+00:00 TriggerDagRunOperator 2021-05-13T22:10:07.835640+00:00 2021-05-13T22:10:08.368366+00:00 0:00:00.532726 27780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:10:05.118376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-13T21:00:00+00:00 TriggerDagRunOperator 2021-05-13T22:10:07.189910+00:00 2021-05-13T22:10:07.579458+00:00 0:00:00.389548 27779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-13T22:10:05.118414+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-13T21:00:00+00:00 EmrJobFlowSensor 2021-05-13T22:00:56.454846+00:00 2021-05-13T22:09:59.425626+00:00 0:09:02.970780 27775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-13T22:00:54.051964+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-13T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-13T22:00:34.271935+00:00 2021-05-13T22:00:35.934841+00:00 0:00:01.662906 27774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-13T22:00:32.035222+00:00 2 default_pool