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-19T17:00:00+00:00 PythonOperator 2021-04-19T18:00:07.453046+00:00 2021-04-19T18:00:11.037857+00:00 0:00:03.584811 18984 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T18:00:04.870500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T16:00:00+00:00 TriggerDagRunOperator 2021-04-19T17:11:18.866869+00:00 2021-04-19T17:11:19.364323+00:00 0:00:00.497454 18976 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:11:16.428112+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T16:00:00+00:00 TriggerDagRunOperator 2021-04-19T17:11:18.712855+00:00 2021-04-19T17:11:19.137774+00:00 0:00:00.424919 18975 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T17:11:16.428162+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T16:00:00+00:00 EmrJobFlowSensor 2021-04-19T17:01:00.290336+00:00 2021-04-19T17:11:03.238206+00:00 0:10:02.947870 18971 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T17:00:57.265625+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T17:00:39.474657+00:00 2021-04-19T17:00:41.154613+00:00 0:00:01.679956 18970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T17:00:37.240800+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T16:00:00+00:00 PythonOperator 2021-04-19T17:00:17.339743+00:00 2021-04-19T17:00:20.327798+00:00 0:00:02.988055 18969 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T17:00:15.063509+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T15:00:00+00:00 TriggerDagRunOperator 2021-04-19T16:09:22.825844+00:00 2021-04-19T16:09:23.350992+00:00 0:00:00.525148 18961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:09:20.511218+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T15:00:00+00:00 TriggerDagRunOperator 2021-04-19T16:09:22.783725+00:00 2021-04-19T16:09:23.198586+00:00 0:00:00.414861 18960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T16:09:20.511252+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T15:00:00+00:00 EmrJobFlowSensor 2021-04-19T16:00:49.851752+00:00 2021-04-19T16:08:52.321832+00:00 0:08:02.470080 18956 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T16:00:47.644028+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T16:00:30.325132+00:00 2021-04-19T16:00:32.098334+00:00 0:00:01.773202 18955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T16:00:27.676567+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T15:00:00+00:00 PythonOperator 2021-04-19T16:00:07.852613+00:00 2021-04-19T16:00:10.958013+00:00 0:00:03.105400 18954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T16:00:05.585604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T14:00:00+00:00 TriggerDagRunOperator 2021-04-19T15:35:53.863070+00:00 2021-04-19T15:35:54.420680+00:00 0:00:00.557610 18947 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:35:51.236377+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T14:00:00+00:00 TriggerDagRunOperator 2021-04-19T15:35:53.687036+00:00 2021-04-19T15:35:54.110839+00:00 0:00:00.423803 18946 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T15:35:51.236429+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T14:00:00+00:00 EmrJobFlowSensor 2021-04-19T15:27:30.830746+00:00 2021-04-19T15:35:33.440825+00:00 0:08:02.610079 18945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T15:27:28.478302+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T15:27:02.713366+00:00 2021-04-19T15:27:04.552154+00:00 0:00:01.838788 18942 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T15:27:00.450885+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T14:00:00+00:00 PythonOperator 2021-04-19T15:26:36.701071+00:00 2021-04-19T15:26:39.649217+00:00 0:00:02.948146 18939 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T15:26:34.425993+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T13:00:00+00:00 TriggerDagRunOperator 2021-04-19T14:10:14.229762+00:00 2021-04-19T14:10:14.756943+00:00 0:00:00.527181 18927 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:10:11.717440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T13:00:00+00:00 TriggerDagRunOperator 2021-04-19T14:10:13.990845+00:00 2021-04-19T14:10:14.411152+00:00 0:00:00.420307 18926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T14:10:11.717488+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T13:00:00+00:00 EmrJobFlowSensor 2021-04-19T14:00:56.878482+00:00 2021-04-19T14:09:59.512998+00:00 0:09:02.634516 18922 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T14:00:54.708361+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T14:00:36.872802+00:00 2021-04-19T14:00:38.547174+00:00 0:00:01.674372 18921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T14:00:34.685907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T13:00:00+00:00 PythonOperator 2021-04-19T14:00:13.116867+00:00 2021-04-19T14:00:16.068254+00:00 0:00:02.951387 18920 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T14:00:10.645505+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T12:00:00+00:00 TriggerDagRunOperator 2021-04-19T13:09:20.229228+00:00 2021-04-19T13:09:20.742036+00:00 0:00:00.512808 18912 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:09:17.853033+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T12:00:00+00:00 TriggerDagRunOperator 2021-04-19T13:09:20.037912+00:00 2021-04-19T13:09:20.442251+00:00 0:00:00.404339 18911 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T13:09:17.853063+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T12:00:00+00:00 EmrJobFlowSensor 2021-04-19T13:01:03.364222+00:00 2021-04-19T13:09:05.866794+00:00 0:08:02.502572 18907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T13:01:01.116927+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T13:00:39.454032+00:00 2021-04-19T13:00:41.125241+00:00 0:00:01.671209 18906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T13:00:37.144732+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T12:00:00+00:00 PythonOperator 2021-04-19T13:00:17.486039+00:00 2021-04-19T13:00:20.492618+00:00 0:00:03.006579 18905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T13:00:15.060343+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T11:00:00+00:00 TriggerDagRunOperator 2021-04-19T12:10:20.920302+00:00 2021-04-19T12:10:21.443795+00:00 0:00:00.523493 18897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:10:18.603525+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T11:00:00+00:00 TriggerDagRunOperator 2021-04-19T12:10:20.833545+00:00 2021-04-19T12:10:21.228452+00:00 0:00:00.394907 18896 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T12:10:18.603497+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T11:00:00+00:00 EmrJobFlowSensor 2021-04-19T12:00:59.837060+00:00 2021-04-19T12:10:02.655769+00:00 0:09:02.818709 18892 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T12:00:57.591662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T12:00:37.753324+00:00 2021-04-19T12:00:40.157110+00:00 0:00:02.403786 18891 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T12:00:35.510735+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T11:00:00+00:00 PythonOperator 2021-04-19T12:00:16.070273+00:00 2021-04-19T12:00:19.020140+00:00 0:00:02.949867 18890 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T12:00:13.543690+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T10:00:00+00:00 TriggerDagRunOperator 2021-04-19T11:11:09.162763+00:00 2021-04-19T11:11:09.689680+00:00 0:00:00.526917 18882 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:11:06.389544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T10:00:00+00:00 TriggerDagRunOperator 2021-04-19T11:11:08.668242+00:00 2021-04-19T11:11:09.103787+00:00 0:00:00.435545 18881 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T11:11:06.389584+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T10:00:00+00:00 EmrJobFlowSensor 2021-04-19T11:00:55.633170+00:00 2021-04-19T11:10:58.418411+00:00 0:10:02.785241 18877 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T11:00:53.382261+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T11:00:34.034974+00:00 2021-04-19T11:00:35.845840+00:00 0:00:01.810866 18876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T11:00:31.339877+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T10:00:00+00:00 PythonOperator 2021-04-19T11:00:11.707177+00:00 2021-04-19T11:00:14.868121+00:00 0:00:03.160944 18875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T11:00:09.244591+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.826658+00:00 2021-04-19T10:23:48.240549+00:00 0:00:00.413891 18868 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T09:00:00+00:00 TriggerDagRunOperator 2021-04-19T10:23:47.829466+00:00 2021-04-19T10:23:48.396461+00:00 0:00:00.566995 18867 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T10:23:45.367042+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T09:00:00+00:00 EmrJobFlowSensor 2021-04-19T10:00:56.651264+00:00 2021-04-19T10:20:01.252457+00:00 0:19:04.601193 18862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T10:00:54.343931+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T10:00:34.817887+00:00 2021-04-19T10:00:36.686036+00:00 0:00:01.868149 18861 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T10:00:32.365480+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T09:00:00+00:00 PythonOperator 2021-04-19T10:00:12.564792+00:00 2021-04-19T10:00:15.740281+00:00 0:00:03.175489 18860 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T10:00:10.222910+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.593355+00:00 2021-04-19T09:10:21.050289+00:00 0:00:00.456934 18852 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T08:00:00+00:00 TriggerDagRunOperator 2021-04-19T09:10:20.614613+00:00 2021-04-19T09:10:21.159833+00:00 0:00:00.545220 18851 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T09:10:18.325815+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T08:00:00+00:00 EmrJobFlowSensor 2021-04-19T09:00:55.724145+00:00 2021-04-19T09:09:58.416079+00:00 0:09:02.691934 18847 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T09:00:53.397617+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T09:00:33.875510+00:00 2021-04-19T09:00:35.856862+00:00 0:00:01.981352 18846 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T09:00:31.450189+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T08:00:00+00:00 PythonOperator 2021-04-19T09:00:11.503624+00:00 2021-04-19T09:00:14.477813+00:00 0:00:02.974189 18845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T09:00:09.287129+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.670461+00:00 2021-04-19T08:13:58.236508+00:00 0:00:00.566047 18838 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536357+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T07:00:00+00:00 TriggerDagRunOperator 2021-04-19T08:13:57.625928+00:00 2021-04-19T08:13:58.046535+00:00 0:00:00.420607 18837 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T08:13:54.536329+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T07:00:00+00:00 EmrJobFlowSensor 2021-04-19T08:00:55.601818+00:00 2021-04-19T08:09:58.093899+00:00 0:09:02.492081 18832 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T08:00:53.295228+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T08:00:35.406788+00:00 2021-04-19T08:00:37.118842+00:00 0:00:01.712054 18831 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T08:00:33.247249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T07:00:00+00:00 PythonOperator 2021-04-19T08:00:13.487301+00:00 2021-04-19T08:00:16.506859+00:00 0:00:03.019558 18830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T08:00:11.192202+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.500741+00:00 2021-04-19T07:10:10.930406+00:00 0:00:00.429665 18823 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T06:00:00+00:00 TriggerDagRunOperator 2021-04-19T07:10:10.537454+00:00 2021-04-19T07:10:11.084321+00:00 0:00:00.546867 18822 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T07:10:08.086562+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T06:00:00+00:00 EmrJobFlowSensor 2021-04-19T07:00:48.873492+00:00 2021-04-19T07:09:51.809454+00:00 0:09:02.935962 18817 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T07:00:46.486728+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T07:00:24.998433+00:00 2021-04-19T07:00:26.831001+00:00 0:00:01.832568 18816 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T07:00:22.546813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T06:00:00+00:00 PythonOperator 2021-04-19T07:00:05.610096+00:00 2021-04-19T07:00:08.774687+00:00 0:00:03.164591 18815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T07:00:02.443849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.840565+00:00 2021-04-19T06:10:30.358942+00:00 0:00:00.518377 18808 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290901+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T05:00:00+00:00 TriggerDagRunOperator 2021-04-19T06:10:29.758133+00:00 2021-04-19T06:10:30.222852+00:00 0:00:00.464719 18807 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T06:10:27.290859+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T05:00:00+00:00 EmrJobFlowSensor 2021-04-19T06:01:08.924701+00:00 2021-04-19T06:10:11.651459+00:00 0:09:02.726758 18802 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T06:01:06.730208+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T06:00:36.878197+00:00 2021-04-19T06:00:38.565338+00:00 0:00:01.687141 18801 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T06:00:34.707803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T05:00:00+00:00 PythonOperator 2021-04-19T06:00:11.159736+00:00 2021-04-19T06:00:14.182779+00:00 0:00:03.023043 18800 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T06:00:08.756338+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T04:00:00+00:00 TriggerDagRunOperator 2021-04-19T05:12:30.698155+00:00 2021-04-19T05:12:31.230429+00:00 0:00:00.532274 18793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:12:28.044866+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T04:00:00+00:00 TriggerDagRunOperator 2021-04-19T05:12:30.595938+00:00 2021-04-19T05:12:31.210905+00:00 0:00:00.614967 18792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T05:12:28.044815+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T04:00:00+00:00 EmrJobFlowSensor 2021-04-19T05:03:23.076662+00:00 2021-04-19T05:12:25.697844+00:00 0:09:02.621182 18788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T05:03:20.727796+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T05:03:01.211088+00:00 2021-04-19T05:03:03.036150+00:00 0:00:01.825062 18787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T05:02:58.768702+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T04:00:00+00:00 PythonOperator 2021-04-19T05:02:41.765851+00:00 2021-04-19T05:02:44.763126+00:00 0:00:02.997275 18786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T05:02:38.703508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.840436+00:00 2021-04-19T04:10:43.384746+00:00 0:00:00.544310 18778 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492324+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T03:00:00+00:00 TriggerDagRunOperator 2021-04-19T04:10:42.683284+00:00 2021-04-19T04:10:43.110648+00:00 0:00:00.427364 18777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T04:10:40.492358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T03:00:00+00:00 EmrJobFlowSensor 2021-04-19T04:01:17.822488+00:00 2021-04-19T04:10:20.445231+00:00 0:09:02.622743 18773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T04:01:15.658600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T04:00:55.809268+00:00 2021-04-19T04:00:58.161168+00:00 0:00:02.351900 18772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T04:00:53.631041+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T03:00:00+00:00 PythonOperator 2021-04-19T04:00:26.027756+00:00 2021-04-19T04:00:28.959890+00:00 0:00:02.932134 18771 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T04:00:23.610719+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T02:00:00+00:00 TriggerDagRunOperator 2021-04-19T03:11:04.857092+00:00 2021-04-19T03:11:05.530592+00:00 0:00:00.673500 18763 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:02.250797+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T02:00:00+00:00 TriggerDagRunOperator 2021-04-19T03:11:04.436574+00:00 2021-04-19T03:11:05.000214+00:00 0:00:00.563640 18762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T03:11:02.250765+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T02:00:00+00:00 EmrJobFlowSensor 2021-04-19T03:00:53.839494+00:00 2021-04-19T03:10:56.668713+00:00 0:10:02.829219 18758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T03:00:51.367575+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T03:00:33.682843+00:00 2021-04-19T03:00:35.728053+00:00 0:00:02.045210 18757 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T03:00:31.288675+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T02:00:00+00:00 PythonOperator 2021-04-19T03:00:11.530623+00:00 2021-04-19T03:00:14.500233+00:00 0:00:02.969610 18756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T03:00:09.248075+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T01:00:00+00:00 TriggerDagRunOperator 2021-04-19T02:11:28.936044+00:00 2021-04-19T02:11:29.456726+00:00 0:00:00.520682 18748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:11:26.506613+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T01:00:00+00:00 TriggerDagRunOperator 2021-04-19T02:11:28.818375+00:00 2021-04-19T02:11:29.215156+00:00 0:00:00.396781 18747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T02:11:26.506577+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T01:00:00+00:00 EmrJobFlowSensor 2021-04-19T02:01:03.901514+00:00 2021-04-19T02:11:06.745917+00:00 0:10:02.844403 18743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T02:01:01.539678+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T02:00:39.863853+00:00 2021-04-19T02:00:41.566632+00:00 0:00:01.702779 18742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T02:00:37.581246+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T01:00:00+00:00 PythonOperator 2021-04-19T02:00:19.835182+00:00 2021-04-19T02:00:22.778183+00:00 0:00:02.943001 18741 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T02:00:17.508756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-19T00:00:00+00:00 TriggerDagRunOperator 2021-04-19T01:09:01.745049+00:00 2021-04-19T01:09:02.147637+00:00 0:00:00.402588 18733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:08:58.857186+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-19T00:00:00+00:00 TriggerDagRunOperator 2021-04-19T01:09:01.412939+00:00 2021-04-19T01:09:01.964547+00:00 0:00:00.551608 18732 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T01:08:58.857238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-19T00:00:00+00:00 EmrJobFlowSensor 2021-04-19T01:00:48.655202+00:00 2021-04-19T01:08:51.185190+00:00 0:08:02.529988 18728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T01:00:45.843908+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-19T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T01:00:26.096602+00:00 2021-04-19T01:00:27.790425+00:00 0:00:01.693823 18727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T01:00:23.860012+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-19T00:00:00+00:00 PythonOperator 2021-04-19T01:00:06.085231+00:00 2021-04-19T01:00:09.205788+00:00 0:00:03.120557 18726 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T01:00:03.753517+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T23:00:00+00:00 TriggerDagRunOperator 2021-04-19T00:11:26.367267+00:00 2021-04-19T00:11:26.961941+00:00 0:00:00.594674 18718 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:11:24.044073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T23:00:00+00:00 TriggerDagRunOperator 2021-04-19T00:11:26.236366+00:00 2021-04-19T00:11:26.697221+00:00 0:00:00.460855 18717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-19T00:11:24.044104+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T23:00:00+00:00 EmrJobFlowSensor 2021-04-19T00:01:03.834098+00:00 2021-04-19T00:11:06.671491+00:00 0:10:02.837393 18713 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-19T00:01:00.952397+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-19T00:00:41.249317+00:00 2021-04-19T00:00:43.082845+00:00 0:00:01.833528 18712 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-19T00:00:38.860469+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T23:00:00+00:00 PythonOperator 2021-04-19T00:00:20.982567+00:00 2021-04-19T00:00:24.278468+00:00 0:00:03.295901 18711 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-19T00:00:18.735538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T22:00:00+00:00 TriggerDagRunOperator 2021-04-18T23:11:39.446951+00:00 2021-04-18T23:11:40.371123+00:00 0:00:00.924172 18703 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:11:37.089466+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T22:00:00+00:00 TriggerDagRunOperator 2021-04-18T23:11:39.385636+00:00 2021-04-18T23:11:39.799686+00:00 0:00:00.414050 18702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T23:11:37.089498+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T22:00:00+00:00 EmrJobFlowSensor 2021-04-18T23:01:04.758166+00:00 2021-04-18T23:11:07.643041+00:00 0:10:02.884875 18698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T23:01:02.008365+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T23:00:44.303118+00:00 2021-04-18T23:00:46.017660+00:00 0:00:01.714542 18697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T23:00:41.988859+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T22:00:00+00:00 PythonOperator 2021-04-18T23:00:22.695720+00:00 2021-04-18T23:00:25.854423+00:00 0:00:03.158703 18696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T23:00:19.968293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T21:00:00+00:00 TriggerDagRunOperator 2021-04-18T22:09:12.238186+00:00 2021-04-18T22:09:12.667213+00:00 0:00:00.429027 18688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:09:09.741111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T21:00:00+00:00 TriggerDagRunOperator 2021-04-18T22:09:11.991304+00:00 2021-04-18T22:09:12.564221+00:00 0:00:00.572917 18687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T22:09:09.741145+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T21:00:00+00:00 EmrJobFlowSensor 2021-04-18T22:01:01.572711+00:00 2021-04-18T22:09:04.189569+00:00 0:08:02.616858 18683 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T22:00:58.853493+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T22:00:39.212581+00:00 2021-04-18T22:00:41.002621+00:00 0:00:01.790040 18682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T22:00:36.775260+00:00 2 default_pool