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-24T17:00:00+00:00 PythonOperator 2021-04-24T18:00:22.317527+00:00 2021-04-24T18:00:25.317262+00:00 0:00:02.999735 20817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T18:00:20.060043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:23.101721+00:00 2021-04-24T17:10:23.617470+00:00 0:00:00.515749 20809 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T16:00:00+00:00 TriggerDagRunOperator 2021-04-24T17:10:22.994308+00:00 2021-04-24T17:10:23.395735+00:00 0:00:00.401427 20808 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T17:10:20.686837+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T16:00:00+00:00 EmrJobFlowSensor 2021-04-24T17:01:00.420832+00:00 2021-04-24T17:10:03.372902+00:00 0:09:02.952070 20804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T17:00:57.850947+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T17:00:38.087973+00:00 2021-04-24T17:00:39.774070+00:00 0:00:01.686097 20803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T17:00:35.846433+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T16:00:00+00:00 PythonOperator 2021-04-24T17:00:18.451776+00:00 2021-04-24T17:00:21.475766+00:00 0:00:03.023990 20802 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T17:00:15.805514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T15:00:00+00:00 TriggerDagRunOperator 2021-04-24T16:10:20.482954+00:00 2021-04-24T16:10:20.900403+00:00 0:00:00.417449 20794 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:10:18.295919+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T15:00:00+00:00 TriggerDagRunOperator 2021-04-24T16:10:20.488643+00:00 2021-04-24T16:10:21.045865+00:00 0:00:00.557222 20793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T16:10:18.295953+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T15:00:00+00:00 EmrJobFlowSensor 2021-04-24T16:01:00.051999+00:00 2021-04-24T16:10:02.959414+00:00 0:09:02.907415 20789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T16:00:57.565600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T16:00:31.709161+00:00 2021-04-24T16:00:33.409012+00:00 0:00:01.699851 20788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T16:00:29.407032+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T15:00:00+00:00 PythonOperator 2021-04-24T16:00:05.695319+00:00 2021-04-24T16:00:08.734576+00:00 0:00:03.039257 20787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T16:00:03.386671+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.270260+00:00 2021-04-24T15:12:27.810742+00:00 0:00:00.540482 20780 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437965+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T14:00:00+00:00 TriggerDagRunOperator 2021-04-24T15:12:27.162332+00:00 2021-04-24T15:12:27.572169+00:00 0:00:00.409837 20779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T15:12:24.437933+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T14:00:00+00:00 EmrJobFlowSensor 2021-04-24T15:00:58.750941+00:00 2021-04-24T15:11:01.535512+00:00 0:10:02.784571 20774 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T15:00:56.262705+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T15:00:38.416879+00:00 2021-04-24T15:00:40.175493+00:00 0:00:01.758614 20773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T15:00:36.191652+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T14:00:00+00:00 PythonOperator 2021-04-24T15:00:16.686716+00:00 2021-04-24T15:00:19.667363+00:00 0:00:02.980647 20772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T15:00:14.178176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.620084+00:00 2021-04-24T14:10:18.176439+00:00 0:00:00.556355 20765 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705799+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T13:00:00+00:00 TriggerDagRunOperator 2021-04-24T14:10:17.575101+00:00 2021-04-24T14:10:18.041820+00:00 0:00:00.466719 20764 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T14:10:14.705833+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T13:00:00+00:00 EmrJobFlowSensor 2021-04-24T14:01:02.059760+00:00 2021-04-24T14:10:04.791238+00:00 0:09:02.731478 20759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T14:00:59.657178+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T14:00:37.686105+00:00 2021-04-24T14:00:39.382293+00:00 0:00:01.696188 20758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T14:00:35.486602+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T13:00:00+00:00 PythonOperator 2021-04-24T14:00:17.526162+00:00 2021-04-24T14:00:20.526024+00:00 0:00:02.999862 20757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T14:00:15.347429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.994406+00:00 2021-04-24T13:11:25.511808+00:00 0:00:00.517402 20750 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T12:00:00+00:00 TriggerDagRunOperator 2021-04-24T13:11:24.953946+00:00 2021-04-24T13:11:25.364862+00:00 0:00:00.410916 20749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T13:11:22.464681+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T12:00:00+00:00 EmrJobFlowSensor 2021-04-24T13:00:58.323647+00:00 2021-04-24T13:11:01.325849+00:00 0:10:03.002202 20744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T13:00:55.900533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T13:00:36.223819+00:00 2021-04-24T13:00:37.897390+00:00 0:00:01.673571 20743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T13:00:33.946532+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T12:00:00+00:00 PythonOperator 2021-04-24T13:00:16.212266+00:00 2021-04-24T13:00:19.214677+00:00 0:00:03.002411 20742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T13:00:13.872011+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.603973+00:00 2021-04-24T12:10:06.115578+00:00 0:00:00.511605 20735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953609+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T11:00:00+00:00 TriggerDagRunOperator 2021-04-24T12:10:05.403440+00:00 2021-04-24T12:10:05.847245+00:00 0:00:00.443805 20734 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T12:10:02.953656+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T11:00:00+00:00 EmrJobFlowSensor 2021-04-24T12:00:55.077452+00:00 2021-04-24T12:09:57.803156+00:00 0:09:02.725704 20729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T12:00:52.766866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T12:00:33.105408+00:00 2021-04-24T12:00:35.004144+00:00 0:00:01.898736 20728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T12:00:30.740225+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T11:00:00+00:00 PythonOperator 2021-04-24T12:00:10.928738+00:00 2021-04-24T12:00:14.030151+00:00 0:00:03.101413 20727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T12:00:08.694885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T10:00:00+00:00 TriggerDagRunOperator 2021-04-24T11:15:35.433617+00:00 2021-04-24T11:15:35.952950+00:00 0:00:00.519333 20720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:15:33.071169+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T10:00:00+00:00 TriggerDagRunOperator 2021-04-24T11:15:35.351916+00:00 2021-04-24T11:15:35.766725+00:00 0:00:00.414809 20719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T11:15:33.071139+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T10:00:00+00:00 EmrJobFlowSensor 2021-04-24T11:05:07.891680+00:00 2021-04-24T11:15:10.638568+00:00 0:10:02.746888 20715 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T11:05:05.559464+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T11:04:45.740987+00:00 2021-04-24T11:04:47.472435+00:00 0:00:01.731448 20714 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T11:04:43.467462+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T10:00:00+00:00 PythonOperator 2021-04-24T11:04:25.804236+00:00 2021-04-24T11:04:28.854345+00:00 0:00:03.050109 20713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T11:04:23.401059+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T09:00:00+00:00 TriggerDagRunOperator 2021-04-24T10:11:16.108247+00:00 2021-04-24T10:11:16.550578+00:00 0:00:00.442331 20705 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:11:13.544370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T09:00:00+00:00 TriggerDagRunOperator 2021-04-24T10:11:16.126226+00:00 2021-04-24T10:11:16.712920+00:00 0:00:00.586694 20704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T10:11:13.544416+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T09:00:00+00:00 EmrJobFlowSensor 2021-04-24T10:00:58.789886+00:00 2021-04-24T10:11:01.605063+00:00 0:10:02.815177 20700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T10:00:56.337003+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T10:00:36.715324+00:00 2021-04-24T10:00:38.425280+00:00 0:00:01.709956 20699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T10:00:34.364151+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T09:00:00+00:00 PythonOperator 2021-04-24T10:00:14.887834+00:00 2021-04-24T10:00:17.898722+00:00 0:00:03.010888 20698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T10:00:12.260357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T08:00:00+00:00 TriggerDagRunOperator 2021-04-24T09:10:08.120529+00:00 2021-04-24T09:10:08.584736+00:00 0:00:00.464207 20690 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:10:05.669360+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T08:00:00+00:00 TriggerDagRunOperator 2021-04-24T09:10:08.035941+00:00 2021-04-24T09:10:08.700201+00:00 0:00:00.664260 20689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T09:10:05.669401+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T08:00:00+00:00 EmrJobFlowSensor 2021-04-24T09:00:52.654759+00:00 2021-04-24T09:09:55.157352+00:00 0:09:02.502593 20685 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T09:00:50.413682+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T09:00:31.035171+00:00 2021-04-24T09:00:32.752497+00:00 0:00:01.717326 20684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T09:00:28.457160+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T08:00:00+00:00 PythonOperator 2021-04-24T09:00:08.879286+00:00 2021-04-24T09:00:11.891218+00:00 0:00:03.011932 20683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T09:00:06.283835+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T07:00:00+00:00 TriggerDagRunOperator 2021-04-24T08:09:55.042822+00:00 2021-04-24T08:09:55.577870+00:00 0:00:00.535048 20675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:09:52.346567+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T07:00:00+00:00 TriggerDagRunOperator 2021-04-24T08:09:54.978832+00:00 2021-04-24T08:09:55.468743+00:00 0:00:00.489911 20674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T08:09:52.346516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T07:00:00+00:00 EmrJobFlowSensor 2021-04-24T08:00:47.522026+00:00 2021-04-24T08:09:50.131247+00:00 0:09:02.609221 20670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T08:00:45.118228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T08:00:25.410915+00:00 2021-04-24T08:00:27.106223+00:00 0:00:01.695308 20669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T08:00:23.158148+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T07:00:00+00:00 PythonOperator 2021-04-24T08:00:05.912448+00:00 2021-04-24T08:00:08.938712+00:00 0:00:03.026264 20668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T08:00:03.147313+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T06:00:00+00:00 TriggerDagRunOperator 2021-04-24T07:10:18.801552+00:00 2021-04-24T07:10:19.313013+00:00 0:00:00.511461 20660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:10:16.206435+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T06:00:00+00:00 TriggerDagRunOperator 2021-04-24T07:10:18.469081+00:00 2021-04-24T07:10:18.895036+00:00 0:00:00.425955 20659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T07:10:16.206393+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T06:00:00+00:00 EmrJobFlowSensor 2021-04-24T07:00:57.706561+00:00 2021-04-24T07:10:00.431855+00:00 0:09:02.725294 20655 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T07:00:55.363069+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T07:00:37.478182+00:00 2021-04-24T07:00:39.166023+00:00 0:00:01.687841 20654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T07:00:35.293243+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T06:00:00+00:00 PythonOperator 2021-04-24T07:00:13.945981+00:00 2021-04-24T07:00:17.002730+00:00 0:00:03.056749 20653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T07:00:11.228300+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T05:00:00+00:00 TriggerDagRunOperator 2021-04-24T06:09:03.519286+00:00 2021-04-24T06:09:04.176733+00:00 0:00:00.657447 20645 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:09:01.151658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T05:00:00+00:00 TriggerDagRunOperator 2021-04-24T06:09:03.457888+00:00 2021-04-24T06:09:03.981536+00:00 0:00:00.523648 20644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T06:09:01.151613+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T05:00:00+00:00 EmrJobFlowSensor 2021-04-24T06:00:52.786543+00:00 2021-04-24T06:08:55.289754+00:00 0:08:02.503211 20640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T06:00:50.226131+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T06:00:30.957310+00:00 2021-04-24T06:00:32.666227+00:00 0:00:01.708917 20639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T06:00:28.357563+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T05:00:00+00:00 PythonOperator 2021-04-24T06:00:08.843436+00:00 2021-04-24T06:00:11.860268+00:00 0:00:03.016832 20638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T06:00:06.188858+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T04:00:00+00:00 TriggerDagRunOperator 2021-04-24T05:10:01.532031+00:00 2021-04-24T05:10:02.075558+00:00 0:00:00.543527 20630 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:09:59.067626+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T04:00:00+00:00 TriggerDagRunOperator 2021-04-24T05:10:01.407338+00:00 2021-04-24T05:10:01.861446+00:00 0:00:00.454108 20629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T05:09:59.067673+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T04:00:00+00:00 EmrJobFlowSensor 2021-04-24T05:00:50.232240+00:00 2021-04-24T05:09:53.032969+00:00 0:09:02.800729 20625 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T05:00:47.804932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T05:00:28.177264+00:00 2021-04-24T05:00:30.254252+00:00 0:00:02.076988 20624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T05:00:25.823078+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T04:00:00+00:00 PythonOperator 2021-04-24T05:00:08.116093+00:00 2021-04-24T05:00:11.107816+00:00 0:00:02.991723 20623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T05:00:05.720153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T03:00:00+00:00 TriggerDagRunOperator 2021-04-24T04:09:16.332413+00:00 2021-04-24T04:09:16.874384+00:00 0:00:00.541971 20615 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:09:13.868640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T03:00:00+00:00 TriggerDagRunOperator 2021-04-24T04:09:16.245888+00:00 2021-04-24T04:09:16.673366+00:00 0:00:00.427478 20614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T04:09:13.868587+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T03:00:00+00:00 EmrJobFlowSensor 2021-04-24T04:01:04.956807+00:00 2021-04-24T04:09:07.623253+00:00 0:08:02.666446 20610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T04:01:02.756325+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T04:00:42.988564+00:00 2021-04-24T04:00:44.720244+00:00 0:00:01.731680 20609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T04:00:40.655405+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T03:00:00+00:00 PythonOperator 2021-04-24T04:00:20.980018+00:00 2021-04-24T04:00:23.943826+00:00 0:00:02.963808 20608 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T04:00:18.638535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T02:00:00+00:00 TriggerDagRunOperator 2021-04-24T03:10:16.137118+00:00 2021-04-24T03:10:16.714652+00:00 0:00:00.577534 20600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:10:13.797545+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T02:00:00+00:00 TriggerDagRunOperator 2021-04-24T03:10:16.115595+00:00 2021-04-24T03:10:16.713866+00:00 0:00:00.598271 20599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T03:10:13.797498+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T02:00:00+00:00 EmrJobFlowSensor 2021-04-24T03:01:00.914340+00:00 2021-04-24T03:10:03.646373+00:00 0:09:02.732033 20595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T03:00:58.559992+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T03:00:38.756687+00:00 2021-04-24T03:00:40.551060+00:00 0:00:01.794373 20594 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T03:00:36.363028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T02:00:00+00:00 PythonOperator 2021-04-24T03:00:19.725794+00:00 2021-04-24T03:00:22.782443+00:00 0:00:03.056649 20593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T03:00:16.326791+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T01:00:00+00:00 TriggerDagRunOperator 2021-04-24T02:09:54.968044+00:00 2021-04-24T02:09:55.400909+00:00 0:00:00.432865 20585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:09:52.155774+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T01:00:00+00:00 TriggerDagRunOperator 2021-04-24T02:09:54.677298+00:00 2021-04-24T02:09:55.211087+00:00 0:00:00.533789 20584 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T02:09:52.155803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T01:00:00+00:00 EmrJobFlowSensor 2021-04-24T02:00:47.566060+00:00 2021-04-24T02:09:50.247796+00:00 0:09:02.681736 20580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T02:00:45.272981+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T02:00:27.778826+00:00 2021-04-24T02:00:29.888839+00:00 0:00:02.110013 20579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T02:00:25.257887+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T01:00:00+00:00 PythonOperator 2021-04-24T02:00:05.795872+00:00 2021-04-24T02:00:08.785896+00:00 0:00:02.990024 20578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T02:00:03.264073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-24T00:00:00+00:00 TriggerDagRunOperator 2021-04-24T01:09:16.299699+00:00 2021-04-24T01:09:16.847992+00:00 0:00:00.548293 20570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T01:09:13.763442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-24T00:00:00+00:00 TriggerDagRunOperator 2021-04-24T01:09:16.168950+00:00 2021-04-24T01:09:16.583955+00:00 0:00:00.415005 20569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T01:09:13.763394+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-24T00:00:00+00:00 EmrJobFlowSensor 2021-04-24T01:00:51.160419+00:00 2021-04-24T01:08:53.688710+00:00 0:08:02.528291 20565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T01:00:48.865045+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-24T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T01:00:29.094896+00:00 2021-04-24T01:00:30.797510+00:00 0:00:01.702614 20564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T01:00:26.798856+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-24T00:00:00+00:00 PythonOperator 2021-04-24T01:00:07.559494+00:00 2021-04-24T01:00:10.552184+00:00 0:00:02.992690 20563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T01:00:04.853967+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T23:00:00+00:00 TriggerDagRunOperator 2021-04-24T00:10:03.303053+00:00 2021-04-24T00:10:04.026127+00:00 0:00:00.723074 20555 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T00:10:00.554822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T23:00:00+00:00 TriggerDagRunOperator 2021-04-24T00:10:03.044427+00:00 2021-04-24T00:10:03.471322+00:00 0:00:00.426895 20554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-24T00:10:00.554866+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T23:00:00+00:00 EmrJobFlowSensor 2021-04-24T00:00:56.029738+00:00 2021-04-24T00:09:58.776770+00:00 0:09:02.747032 20550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-24T00:00:53.649859+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-24T00:00:33.836151+00:00 2021-04-24T00:00:35.542055+00:00 0:00:01.705904 20549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-24T00:00:31.593065+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T23:00:00+00:00 PythonOperator 2021-04-24T00:00:11.764507+00:00 2021-04-24T00:00:14.696584+00:00 0:00:02.932077 20548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-24T00:00:09.518087+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T22:00:00+00:00 TriggerDagRunOperator 2021-04-23T23:13:17.806957+00:00 2021-04-23T23:13:18.366642+00:00 0:00:00.559685 20541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:13:15.135126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T22:00:00+00:00 TriggerDagRunOperator 2021-04-23T23:13:17.586838+00:00 2021-04-23T23:13:18.028584+00:00 0:00:00.441746 20540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T23:13:15.135155+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T22:00:00+00:00 EmrJobFlowSensor 2021-04-23T23:01:06.143856+00:00 2021-04-23T23:10:09.170246+00:00 0:09:03.026390 20534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T23:01:03.808608+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T23:00:44.253109+00:00 2021-04-23T23:00:46.133234+00:00 0:00:01.880125 20532 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T23:00:41.788595+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-23T22:00:00+00:00 PythonOperator 2021-04-23T23:00:21.959315+00:00 2021-04-23T23:00:24.904314+00:00 0:00:02.944999 20530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-23T23:00:19.702692+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-23T21:00:00+00:00 TriggerDagRunOperator 2021-04-23T22:10:21.417073+00:00 2021-04-23T22:10:21.929698+00:00 0:00:00.512625 20523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:10:18.754181+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-23T21:00:00+00:00 TriggerDagRunOperator 2021-04-23T22:10:21.347251+00:00 2021-04-23T22:10:21.772511+00:00 0:00:00.425260 20522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-23T22:10:18.754139+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-23T21:00:00+00:00 EmrJobFlowSensor 2021-04-23T22:01:03.032262+00:00 2021-04-23T22:10:05.767652+00:00 0:09:02.735390 20517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-23T22:01:00.681704+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-23T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-23T22:00:40.811112+00:00 2021-04-23T22:00:42.462200+00:00 0:00:01.651088 20516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-23T22:00:38.642679+00:00 2 default_pool