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-22T05:00:00+00:00 PythonOperator 2021-04-22T06:00:09.899403+00:00 2021-04-22T06:00:13.095355+00:00 0:00:03.195952 19903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T06:00:07.443172+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T04:00:00+00:00 TriggerDagRunOperator 2021-04-22T05:12:07.137664+00:00 2021-04-22T05:12:07.586785+00:00 0:00:00.449121 19896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:12:04.731538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T04:00:00+00:00 TriggerDagRunOperator 2021-04-22T05:12:07.024848+00:00 2021-04-22T05:12:07.591322+00:00 0:00:00.566474 19895 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T05:12:04.731504+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T04:00:00+00:00 EmrJobFlowSensor 2021-04-22T05:00:47.934120+00:00 2021-04-22T05:11:50.793755+00:00 0:11:02.859635 19890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T05:00:45.582262+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T05:00:27.657433+00:00 2021-04-22T05:00:29.329379+00:00 0:00:01.671946 19889 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T05:00:25.505317+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T04:00:00+00:00 PythonOperator 2021-04-22T05:00:05.695725+00:00 2021-04-22T05:00:09.015128+00:00 0:00:03.319403 19888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T05:00:03.482922+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T03:00:00+00:00 TriggerDagRunOperator 2021-04-22T04:11:21.134866+00:00 2021-04-22T04:11:21.636469+00:00 0:00:00.501603 19881 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:11:18.258376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T03:00:00+00:00 TriggerDagRunOperator 2021-04-22T04:11:20.791755+00:00 2021-04-22T04:11:21.295650+00:00 0:00:00.503895 19880 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T04:11:18.258426+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T03:00:00+00:00 EmrJobFlowSensor 2021-04-22T04:01:12.610022+00:00 2021-04-22T04:11:15.613522+00:00 0:10:03.003500 19875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T04:01:10.285889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T04:00:50.498629+00:00 2021-04-22T04:00:52.187794+00:00 0:00:01.689165 19874 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T04:00:48.270436+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T03:00:00+00:00 PythonOperator 2021-04-22T04:00:19.030422+00:00 2021-04-22T04:00:21.999930+00:00 0:00:02.969508 19873 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T04:00:16.245683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T02:00:00+00:00 TriggerDagRunOperator 2021-04-22T03:12:38.712661+00:00 2021-04-22T03:12:39.128066+00:00 0:00:00.415405 19866 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T03:12:35.625627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T02:00:00+00:00 TriggerDagRunOperator 2021-04-22T03:12:38.705535+00:00 2021-04-22T03:12:39.252421+00:00 0:00:00.546886 19865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T03:12:35.625579+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T02:00:00+00:00 EmrJobFlowSensor 2021-04-22T03:01:03.185257+00:00 2021-04-22T03:12:06.228862+00:00 0:11:03.043605 19860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T03:01:00.847875+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T03:00:40.995027+00:00 2021-04-22T03:00:42.715413+00:00 0:00:01.720386 19859 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T03:00:38.792764+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T02:00:00+00:00 PythonOperator 2021-04-22T03:00:19.096750+00:00 2021-04-22T03:00:22.076804+00:00 0:00:02.980054 19858 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T03:00:16.759794+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T01:00:00+00:00 TriggerDagRunOperator 2021-04-22T02:14:04.996712+00:00 2021-04-22T02:14:05.520245+00:00 0:00:00.523533 19851 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T02:14:02.538396+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T01:00:00+00:00 TriggerDagRunOperator 2021-04-22T02:14:04.943372+00:00 2021-04-22T02:14:05.599206+00:00 0:00:00.655834 19850 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T02:14:02.538319+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T01:00:00+00:00 EmrJobFlowSensor 2021-04-22T02:03:47.919884+00:00 2021-04-22T02:13:50.813983+00:00 0:10:02.894099 19846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T02:03:45.578678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T02:03:26.591071+00:00 2021-04-22T02:03:28.355008+00:00 0:00:01.763937 19845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T02:03:23.500747+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T01:00:00+00:00 PythonOperator 2021-04-22T02:03:06.111179+00:00 2021-04-22T02:03:09.125421+00:00 0:00:03.014242 19844 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T02:03:03.485489+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-22T00:00:00+00:00 TriggerDagRunOperator 2021-04-22T01:12:10.027636+00:00 2021-04-22T01:12:10.581255+00:00 0:00:00.553619 19836 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:12:07.653697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-22T00:00:00+00:00 TriggerDagRunOperator 2021-04-22T01:12:09.881515+00:00 2021-04-22T01:12:10.315593+00:00 0:00:00.434078 19835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T01:12:07.653668+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-22T00:00:00+00:00 EmrJobFlowSensor 2021-04-22T01:00:58.961256+00:00 2021-04-22T01:12:01.979730+00:00 0:11:03.018474 19831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T01:00:56.646407+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-22T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T01:00:39.098584+00:00 2021-04-22T01:00:40.908418+00:00 0:00:01.809834 19830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T01:00:36.568267+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-22T00:00:00+00:00 PythonOperator 2021-04-22T01:00:16.898921+00:00 2021-04-22T01:00:20.097116+00:00 0:00:03.198195 19829 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T01:00:14.467916+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T23:00:00+00:00 TriggerDagRunOperator 2021-04-22T00:11:15.894488+00:00 2021-04-22T00:11:16.275035+00:00 0:00:00.380547 19821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:11:13.087789+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T23:00:00+00:00 TriggerDagRunOperator 2021-04-22T00:11:15.348442+00:00 2021-04-22T00:11:15.868612+00:00 0:00:00.520170 19820 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-22T00:11:13.087834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T23:00:00+00:00 EmrJobFlowSensor 2021-04-22T00:01:08.904870+00:00 2021-04-22T00:11:11.793738+00:00 0:10:02.888868 19816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-22T00:01:06.242930+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-22T00:00:42.921329+00:00 2021-04-22T00:00:44.656606+00:00 0:00:01.735277 19815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-22T00:00:40.091465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T23:00:00+00:00 PythonOperator 2021-04-22T00:00:22.841703+00:00 2021-04-22T00:00:25.836729+00:00 0:00:02.995026 19814 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-22T00:00:20.029218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T22:00:00+00:00 TriggerDagRunOperator 2021-04-21T23:11:15.116524+00:00 2021-04-21T23:11:15.546035+00:00 0:00:00.429511 19806 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:11:12.747637+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T22:00:00+00:00 TriggerDagRunOperator 2021-04-21T23:11:15.080143+00:00 2021-04-21T23:11:15.614903+00:00 0:00:00.534760 19805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T23:11:12.747611+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T22:00:00+00:00 EmrJobFlowSensor 2021-04-21T23:01:04.183241+00:00 2021-04-21T23:11:06.954037+00:00 0:10:02.770796 19801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T23:01:01.931378+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T23:00:42.336823+00:00 2021-04-21T23:00:44.016497+00:00 0:00:01.679674 19800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T23:00:39.912888+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T22:00:00+00:00 PythonOperator 2021-04-21T23:00:20.485424+00:00 2021-04-21T23:00:23.538764+00:00 0:00:03.053340 19799 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T23:00:17.895569+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T21:00:00+00:00 TriggerDagRunOperator 2021-04-21T22:11:07.527917+00:00 2021-04-21T22:11:08.043720+00:00 0:00:00.515803 19791 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:11:05.066849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T21:00:00+00:00 TriggerDagRunOperator 2021-04-21T22:11:07.420798+00:00 2021-04-21T22:11:07.857415+00:00 0:00:00.436617 19790 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T22:11:05.066798+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T21:00:00+00:00 EmrJobFlowSensor 2021-04-21T22:00:52.311624+00:00 2021-04-21T22:10:55.077208+00:00 0:10:02.765584 19786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T22:00:50.145333+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T22:00:30.437533+00:00 2021-04-21T22:00:32.306738+00:00 0:00:01.869205 19785 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T22:00:28.148336+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T21:00:00+00:00 PythonOperator 2021-04-21T22:00:10.728371+00:00 2021-04-21T22:00:13.671895+00:00 0:00:02.943524 19784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T22:00:08.021665+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T20:00:00+00:00 TriggerDagRunOperator 2021-04-21T21:10:25.441499+00:00 2021-04-21T21:10:25.962075+00:00 0:00:00.520576 19776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:10:23.004129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T20:00:00+00:00 TriggerDagRunOperator 2021-04-21T21:10:25.238701+00:00 2021-04-21T21:10:25.650554+00:00 0:00:00.411853 19775 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T21:10:23.004158+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T20:00:00+00:00 EmrJobFlowSensor 2021-04-21T21:01:12.014641+00:00 2021-04-21T21:10:14.754258+00:00 0:09:02.739617 19771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T21:01:09.825424+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T21:00:48.105407+00:00 2021-04-21T21:00:50.319358+00:00 0:00:02.213951 19770 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T21:00:45.803148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T20:00:00+00:00 PythonOperator 2021-04-21T21:00:24.498327+00:00 2021-04-21T21:00:27.461327+00:00 0:00:02.963000 19769 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T21:00:21.789679+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T19:00:00+00:00 TriggerDagRunOperator 2021-04-21T20:12:12.640694+00:00 2021-04-21T20:12:13.218602+00:00 0:00:00.577908 19761 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:12:10.363355+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T19:00:00+00:00 TriggerDagRunOperator 2021-04-21T20:12:12.570220+00:00 2021-04-21T20:12:13.052821+00:00 0:00:00.482601 19760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T20:12:10.363389+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T19:00:00+00:00 EmrJobFlowSensor 2021-04-21T20:00:55.922720+00:00 2021-04-21T20:11:58.848976+00:00 0:11:02.926256 19756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T20:00:53.366244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T20:00:33.667725+00:00 2021-04-21T20:00:35.648231+00:00 0:00:01.980506 19755 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T20:00:31.360296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T19:00:00+00:00 PythonOperator 2021-04-21T20:00:11.658280+00:00 2021-04-21T20:00:14.825487+00:00 0:00:03.167207 19754 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T20:00:09.284370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T18:00:00+00:00 TriggerDagRunOperator 2021-04-21T19:11:36.239032+00:00 2021-04-21T19:11:36.711346+00:00 0:00:00.472314 19746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:11:33.915793+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T18:00:00+00:00 TriggerDagRunOperator 2021-04-21T19:11:36.237905+00:00 2021-04-21T19:11:36.792698+00:00 0:00:00.554793 19745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T19:11:33.915826+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T18:00:00+00:00 EmrJobFlowSensor 2021-04-21T19:01:03.310119+00:00 2021-04-21T19:11:06.280874+00:00 0:10:02.970755 19741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T19:01:00.952991+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T19:00:40.961408+00:00 2021-04-21T19:00:42.680835+00:00 0:00:01.719427 19740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T19:00:38.772381+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T18:00:00+00:00 PythonOperator 2021-04-21T19:00:19.123382+00:00 2021-04-21T19:00:22.079513+00:00 0:00:02.956131 19739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T19:00:16.695414+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T17:00:00+00:00 TriggerDagRunOperator 2021-04-21T18:11:10.417496+00:00 2021-04-21T18:11:10.850858+00:00 0:00:00.433362 19731 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T18:11:07.896155+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T17:00:00+00:00 TriggerDagRunOperator 2021-04-21T18:11:10.266583+00:00 2021-04-21T18:11:10.809578+00:00 0:00:00.542995 19730 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T18:11:07.896123+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T17:00:00+00:00 EmrJobFlowSensor 2021-04-21T18:00:57.196980+00:00 2021-04-21T18:11:00.115714+00:00 0:10:02.918734 19726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T18:00:54.989185+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T18:00:37.204688+00:00 2021-04-21T18:00:39.085666+00:00 0:00:01.880978 19725 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T18:00:34.948365+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T17:00:00+00:00 PythonOperator 2021-04-21T18:00:07.855580+00:00 2021-04-21T18:00:11.219637+00:00 0:00:03.364057 19724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T18:00:04.927465+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T16:00:00+00:00 TriggerDagRunOperator 2021-04-21T17:10:06.409774+00:00 2021-04-21T17:10:06.814142+00:00 0:00:00.404368 19716 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:10:03.500901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T16:00:00+00:00 TriggerDagRunOperator 2021-04-21T17:10:05.754106+00:00 2021-04-21T17:10:06.241379+00:00 0:00:00.487273 19715 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T17:10:03.500935+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T16:00:00+00:00 EmrJobFlowSensor 2021-04-21T17:00:56.499085+00:00 2021-04-21T17:09:59.179085+00:00 0:09:02.680000 19711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T17:00:54.337709+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T17:00:36.507220+00:00 2021-04-21T17:00:38.232014+00:00 0:00:01.724794 19710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T17:00:34.317475+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T16:00:00+00:00 PythonOperator 2021-04-21T17:00:14.838068+00:00 2021-04-21T17:00:17.858806+00:00 0:00:03.020738 19709 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T17:00:12.201592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T15:00:00+00:00 TriggerDagRunOperator 2021-04-21T16:12:29.703118+00:00 2021-04-21T16:12:30.221454+00:00 0:00:00.518336 19701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:12:27.264643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T15:00:00+00:00 TriggerDagRunOperator 2021-04-21T16:12:29.466801+00:00 2021-04-21T16:12:29.890966+00:00 0:00:00.424165 19700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T16:12:27.264609+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T15:00:00+00:00 EmrJobFlowSensor 2021-04-21T16:00:54.185901+00:00 2021-04-21T16:11:57.159568+00:00 0:11:02.973667 19696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T16:00:51.940135+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T16:00:34.362440+00:00 2021-04-21T16:00:36.047602+00:00 0:00:01.685162 19695 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T16:00:31.924307+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T15:00:00+00:00 PythonOperator 2021-04-21T16:00:10.331075+00:00 2021-04-21T16:00:13.342715+00:00 0:00:03.011640 19694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T16:00:07.902684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T14:00:00+00:00 TriggerDagRunOperator 2021-04-21T15:24:00.910794+00:00 2021-04-21T15:24:01.467040+00:00 0:00:00.556246 19687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:23:58.172119+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T14:00:00+00:00 TriggerDagRunOperator 2021-04-21T15:24:00.897963+00:00 2021-04-21T15:24:01.325862+00:00 0:00:00.427899 19686 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T15:23:58.172171+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T14:00:00+00:00 EmrJobFlowSensor 2021-04-21T15:14:35.322650+00:00 2021-04-21T15:23:38.024290+00:00 0:09:02.701640 19685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T15:14:33.078598+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T15:14:13.362635+00:00 2021-04-21T15:14:15.250469+00:00 0:00:01.887834 19683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T15:14:10.990979+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T14:00:00+00:00 PythonOperator 2021-04-21T15:13:51.436618+00:00 2021-04-21T15:13:54.416625+00:00 0:00:02.980007 19681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T15:13:48.913026+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T13:00:00+00:00 TriggerDagRunOperator 2021-04-21T14:11:08.905925+00:00 2021-04-21T14:11:09.418655+00:00 0:00:00.512730 19669 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:11:06.489055+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T13:00:00+00:00 TriggerDagRunOperator 2021-04-21T14:11:08.782447+00:00 2021-04-21T14:11:09.218710+00:00 0:00:00.436263 19668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T14:11:06.489092+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T13:00:00+00:00 EmrJobFlowSensor 2021-04-21T14:00:49.885997+00:00 2021-04-21T14:10:52.665191+00:00 0:10:02.779194 19664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T14:00:47.586690+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T14:00:29.944091+00:00 2021-04-21T14:00:31.735103+00:00 0:00:01.791012 19663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T14:00:27.553005+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T13:00:00+00:00 PythonOperator 2021-04-21T14:00:07.768940+00:00 2021-04-21T14:00:11.010427+00:00 0:00:03.241487 19662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T14:00:05.464592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T12:00:00+00:00 TriggerDagRunOperator 2021-04-21T13:10:56.002051+00:00 2021-04-21T13:10:56.428201+00:00 0:00:00.426150 19654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:10:53.422744+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T12:00:00+00:00 TriggerDagRunOperator 2021-04-21T13:10:55.832246+00:00 2021-04-21T13:10:56.407894+00:00 0:00:00.575648 19653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T13:10:53.422713+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T12:00:00+00:00 EmrJobFlowSensor 2021-04-21T13:00:48.399601+00:00 2021-04-21T13:10:51.210252+00:00 0:10:02.810651 19649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T13:00:46.253296+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T13:00:26.459266+00:00 2021-04-21T13:00:28.299356+00:00 0:00:01.840090 19648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T13:00:24.230491+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T12:00:00+00:00 PythonOperator 2021-04-21T13:00:04.952256+00:00 2021-04-21T13:00:08.123228+00:00 0:00:03.170972 19647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T13:00:02.262478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T11:00:00+00:00 TriggerDagRunOperator 2021-04-21T12:11:00.448237+00:00 2021-04-21T12:11:00.961392+00:00 0:00:00.513155 19636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:10:57.853761+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T11:00:00+00:00 TriggerDagRunOperator 2021-04-21T12:11:00.249402+00:00 2021-04-21T12:11:00.671683+00:00 0:00:00.422281 19635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T12:10:57.853714+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T11:00:00+00:00 EmrJobFlowSensor 2021-04-21T12:00:46.805633+00:00 2021-04-21T12:10:49.636299+00:00 0:10:02.830666 19631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T12:00:44.661801+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T12:00:26.859788+00:00 2021-04-21T12:00:28.551959+00:00 0:00:01.692171 19630 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T12:00:24.634626+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T11:00:00+00:00 PythonOperator 2021-04-21T12:00:05.304021+00:00 2021-04-21T12:00:08.270044+00:00 0:00:02.966023 19629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T12:00:02.622883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:28.047955+00:00 2021-04-21T11:12:28.654844+00:00 0:00:00.606889 19621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791020+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T10:00:00+00:00 TriggerDagRunOperator 2021-04-21T11:12:27.997035+00:00 2021-04-21T11:12:28.411079+00:00 0:00:00.414044 19620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T11:12:25.791052+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T10:00:00+00:00 EmrJobFlowSensor 2021-04-21T11:01:09.274689+00:00 2021-04-21T11:12:12.290890+00:00 0:11:03.016201 19616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T11:01:06.687794+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T11:00:44.875212+00:00 2021-04-21T11:00:46.578188+00:00 0:00:01.702976 19615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T11:00:42.664563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-21T10:00:00+00:00 PythonOperator 2021-04-21T11:00:13.518431+00:00 2021-04-21T11:00:17.077994+00:00 0:00:03.559563 19614 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-21T11:00:10.635420+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.671353+00:00 2021-04-21T10:12:08.194838+00:00 0:00:00.523485 19606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167697+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-21T09:00:00+00:00 TriggerDagRunOperator 2021-04-21T10:12:07.561491+00:00 2021-04-21T10:12:07.983420+00:00 0:00:00.421929 19605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-21T10:12:05.167658+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-21T09:00:00+00:00 EmrJobFlowSensor 2021-04-21T10:00:48.388920+00:00 2021-04-21T10:11:51.333109+00:00 0:11:02.944189 19601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-21T10:00:46.058531+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-21T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-21T10:00:26.335728+00:00 2021-04-21T10:00:28.201150+00:00 0:00:01.865422 19600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-21T10:00:23.976031+00:00 2 default_pool