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-03-20T02:00:00+00:00 PythonOperator 2021-03-20T03:00:20.111438+00:00 2021-03-20T03:00:22.910161+00:00 0:00:02.798723 9986 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T03:00:17.718461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T01:00:00+00:00 TriggerDagRunOperator 2021-03-20T02:11:15.177819+00:00 2021-03-20T02:11:15.742541+00:00 0:00:00.564722 9982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T02:11:12.604405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T01:00:00+00:00 TriggerDagRunOperator 2021-03-20T02:11:14.985531+00:00 2021-03-20T02:11:15.401381+00:00 0:00:00.415850 9981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T02:11:12.604378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T01:00:00+00:00 EmrJobFlowSensor 2021-03-20T02:00:58.055210+00:00 2021-03-20T02:11:00.854234+00:00 0:10:02.799024 9979 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T02:00:55.759485+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T01:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T02:00:42.015585+00:00 2021-03-20T02:00:43.854812+00:00 0:00:01.839227 9978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T02:00:39.696573+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T01:00:00+00:00 PythonOperator 2021-03-20T02:00:13.926182+00:00 2021-03-20T02:00:16.637173+00:00 0:00:02.710991 9977 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T02:00:11.681638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-20T00:00:00+00:00 TriggerDagRunOperator 2021-03-20T01:10:13.139281+00:00 2021-03-20T01:10:13.571660+00:00 0:00:00.432379 9973 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T01:10:10.375439+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-20T00:00:00+00:00 TriggerDagRunOperator 2021-03-20T01:10:13.126433+00:00 2021-03-20T01:10:13.723999+00:00 0:00:00.597566 9972 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T01:10:10.375482+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-20T00:00:00+00:00 EmrJobFlowSensor 2021-03-20T01:00:51.323016+00:00 2021-03-20T01:09:53.953886+00:00 0:09:02.630870 9970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T01:00:49.135600+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-20T00:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T01:00:27.389627+00:00 2021-03-20T01:00:29.230380+00:00 0:00:01.840753 9969 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T01:00:25.116831+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-20T00:00:00+00:00 PythonOperator 2021-03-20T01:00:11.340877+00:00 2021-03-20T01:00:14.109103+00:00 0:00:02.768226 9968 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T01:00:09.092562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T23:00:00+00:00 TriggerDagRunOperator 2021-03-20T00:09:50.710498+00:00 2021-03-20T00:09:51.230563+00:00 0:00:00.520065 9964 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T00:09:47.336659+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T23:00:00+00:00 TriggerDagRunOperator 2021-03-20T00:09:50.068040+00:00 2021-03-20T00:09:50.481258+00:00 0:00:00.413218 9963 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-20T00:09:47.336686+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T23:00:00+00:00 EmrJobFlowSensor 2021-03-20T00:00:40.684194+00:00 2021-03-20T00:09:43.491959+00:00 0:09:02.807765 9961 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-20T00:00:38.319095+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-03-20T00:00:24.434989+00:00 2021-03-20T00:00:26.175601+00:00 0:00:01.740612 9960 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-20T00:00:22.282904+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T23:00:00+00:00 PythonOperator 2021-03-20T00:00:06.710122+00:00 2021-03-20T00:00:09.453951+00:00 0:00:02.743829 9959 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-20T00:00:04.324552+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T22:00:00+00:00 TriggerDagRunOperator 2021-03-19T23:10:06.928329+00:00 2021-03-19T23:10:07.483801+00:00 0:00:00.555472 9955 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T23:10:04.581306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T22:00:00+00:00 TriggerDagRunOperator 2021-03-19T23:10:06.911617+00:00 2021-03-19T23:10:07.305357+00:00 0:00:00.393740 9954 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T23:10:04.581334+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T22:00:00+00:00 EmrJobFlowSensor 2021-03-19T23:01:46.212613+00:00 2021-03-19T23:09:48.830283+00:00 0:08:02.617670 9953 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T23:01:43.832969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T22:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T23:01:30.021473+00:00 2021-03-19T23:01:31.734554+00:00 0:00:01.713081 9952 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T23:01:27.723024+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T22:00:00+00:00 PythonOperator 2021-03-19T23:01:14.461149+00:00 2021-03-19T23:01:17.166067+00:00 0:00:02.704918 9951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T23:01:11.764306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T21:00:00+00:00 TriggerDagRunOperator 2021-03-19T22:11:22.834411+00:00 2021-03-19T22:11:23.362633+00:00 0:00:00.528222 9946 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T22:11:20.251541+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T21:00:00+00:00 TriggerDagRunOperator 2021-03-19T22:11:22.604341+00:00 2021-03-19T22:11:23.009310+00:00 0:00:00.404969 9945 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T22:11:20.251500+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T21:00:00+00:00 EmrJobFlowSensor 2021-03-19T22:00:59.131371+00:00 2021-03-19T22:11:02.000792+00:00 0:10:02.869421 9944 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T22:00:56.977063+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T21:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T22:00:37.317667+00:00 2021-03-19T22:00:39.198521+00:00 0:00:01.880854 9943 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T22:00:34.960096+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T21:00:00+00:00 PythonOperator 2021-03-19T22:00:19.331372+00:00 2021-03-19T22:00:22.049578+00:00 0:00:02.718206 9942 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T22:00:16.887940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T20:00:00+00:00 TriggerDagRunOperator 2021-03-19T21:09:55.203303+00:00 2021-03-19T21:09:55.740683+00:00 0:00:00.537380 9937 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T21:09:52.530148+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T20:00:00+00:00 TriggerDagRunOperator 2021-03-19T21:09:54.811326+00:00 2021-03-19T21:09:55.221230+00:00 0:00:00.409904 9936 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T21:09:52.530119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T20:00:00+00:00 EmrJobFlowSensor 2021-03-19T21:00:43.840207+00:00 2021-03-19T21:09:46.756923+00:00 0:09:02.916716 9935 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T21:00:41.338710+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T20:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T21:00:27.417459+00:00 2021-03-19T21:00:29.179838+00:00 0:00:01.762379 9934 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T21:00:25.267310+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T20:00:00+00:00 PythonOperator 2021-03-19T21:00:10.075700+00:00 2021-03-19T21:00:12.947016+00:00 0:00:02.871316 9933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T21:00:07.256559+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T19:00:00+00:00 TriggerDagRunOperator 2021-03-19T20:11:05.290670+00:00 2021-03-19T20:11:05.838774+00:00 0:00:00.548104 9928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T20:11:02.986792+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T19:00:00+00:00 TriggerDagRunOperator 2021-03-19T20:11:05.204182+00:00 2021-03-19T20:11:05.647865+00:00 0:00:00.443683 9927 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T20:11:02.986760+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T19:00:00+00:00 EmrJobFlowSensor 2021-03-19T20:00:48.032216+00:00 2021-03-19T20:10:50.740368+00:00 0:10:02.708152 9926 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T20:00:45.876683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T19:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T20:00:30.468015+00:00 2021-03-19T20:00:32.348503+00:00 0:00:01.880488 9925 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T20:00:27.937410+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T19:00:00+00:00 PythonOperator 2021-03-19T20:00:14.365345+00:00 2021-03-19T20:00:17.068869+00:00 0:00:02.703524 9924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T20:00:11.843078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T18:00:00+00:00 TriggerDagRunOperator 2021-03-19T19:11:11.902251+00:00 2021-03-19T19:11:12.470067+00:00 0:00:00.567816 9919 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T19:11:09.686733+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T18:00:00+00:00 TriggerDagRunOperator 2021-03-19T19:11:11.818189+00:00 2021-03-19T19:11:12.211153+00:00 0:00:00.392964 9918 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T19:11:09.686704+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T18:00:00+00:00 EmrJobFlowSensor 2021-03-19T19:00:50.850365+00:00 2021-03-19T19:10:53.826983+00:00 0:10:02.976618 9917 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T19:00:48.607640+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T18:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T19:00:28.828989+00:00 2021-03-19T19:00:30.502739+00:00 0:00:01.673750 9916 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T19:00:26.586758+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T18:00:00+00:00 PythonOperator 2021-03-19T19:00:10.975263+00:00 2021-03-19T19:00:13.844386+00:00 0:00:02.869123 9915 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T19:00:08.572923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T17:00:00+00:00 TriggerDagRunOperator 2021-03-19T18:11:08.076625+00:00 2021-03-19T18:11:08.620984+00:00 0:00:00.544359 9910 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T18:11:05.664674+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T17:00:00+00:00 TriggerDagRunOperator 2021-03-19T18:11:07.804032+00:00 2021-03-19T18:11:08.226321+00:00 0:00:00.422289 9909 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T18:11:05.664644+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T17:00:00+00:00 EmrJobFlowSensor 2021-03-19T18:00:59.085546+00:00 2021-03-19T18:11:02.173648+00:00 0:10:03.088102 9908 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T18:00:56.581230+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T17:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T18:00:40.929077+00:00 2021-03-19T18:00:42.693492+00:00 0:00:01.764415 9907 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T18:00:38.635035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T17:00:00+00:00 PythonOperator 2021-03-19T18:00:24.879805+00:00 2021-03-19T18:00:27.676033+00:00 0:00:02.796228 9906 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T18:00:22.554936+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T16:00:00+00:00 TriggerDagRunOperator 2021-03-19T17:10:12.103407+00:00 2021-03-19T17:10:12.547463+00:00 0:00:00.444056 9901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T17:10:09.791844+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T16:00:00+00:00 TriggerDagRunOperator 2021-03-19T17:10:12.128523+00:00 2021-03-19T17:10:12.756022+00:00 0:00:00.627499 9900 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T17:10:09.791814+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T16:00:00+00:00 EmrJobFlowSensor 2021-03-19T17:00:52.926222+00:00 2021-03-19T17:09:55.344723+00:00 0:09:02.418501 9899 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T17:00:50.652948+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T16:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T17:00:35.051999+00:00 2021-03-19T17:00:36.742746+00:00 0:00:01.690747 9898 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T17:00:32.623249+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T16:00:00+00:00 PythonOperator 2021-03-19T17:00:19.583393+00:00 2021-03-19T17:00:22.466079+00:00 0:00:02.882686 9897 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T17:00:16.544278+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T15:00:00+00:00 TriggerDagRunOperator 2021-03-19T16:11:58.502561+00:00 2021-03-19T16:11:59.026874+00:00 0:00:00.524313 9889 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T16:11:55.822969+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T15:00:00+00:00 TriggerDagRunOperator 2021-03-19T16:11:58.357014+00:00 2021-03-19T16:11:58.774116+00:00 0:00:00.417102 9888 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T16:11:55.823012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T15:00:00+00:00 EmrJobFlowSensor 2021-03-19T16:00:42.769956+00:00 2021-03-19T16:11:45.579843+00:00 0:11:02.809887 9886 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T16:00:40.434350+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T15:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T16:00:26.916371+00:00 2021-03-19T16:00:28.740371+00:00 0:00:01.824000 9885 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T16:00:24.358004+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T15:00:00+00:00 PythonOperator 2021-03-19T16:00:10.727597+00:00 2021-03-19T16:00:13.514906+00:00 0:00:02.787309 9884 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T16:00:08.307562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-19T14:00:00+00:00 TriggerDagRunOperator 2021-03-19T15:29:42.093002+00:00 2021-03-19T15:29:42.747339+00:00 0:00:00.654337 9876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T15:29:39.799352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-19T14:00:00+00:00 TriggerDagRunOperator 2021-03-19T15:29:42.028573+00:00 2021-03-19T15:29:42.415989+00:00 0:00:00.387416 9875 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-19T15:29:39.799379+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-19T14:00:00+00:00 EmrJobFlowSensor 2021-03-19T15:08:13.713385+00:00 2021-03-19T15:29:18.067928+00:00 0:21:04.354543 9867 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-19T15:08:11.402620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-19T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-19T15:07:57.695083+00:00 2021-03-19T15:07:59.583953+00:00 0:00:01.888870 9864 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-19T15:07:55.385513+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-19T14:00:00+00:00 PythonOperator 2021-03-19T15:07:40.087547+00:00 2021-03-19T15:07:42.983848+00:00 0:00:02.896301 9863 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-19T15:07:37.426103+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-17T13:00:00+00:00 TriggerDagRunOperator 2021-03-17T14:12:13.847492+00:00 2021-03-17T14:12:14.410759+00:00 0:00:00.563267 9804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T14:12:10.993605+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-17T13:00:00+00:00 TriggerDagRunOperator 2021-03-17T14:12:13.712127+00:00 2021-03-17T14:12:14.135699+00:00 0:00:00.423572 9803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T14:12:10.993639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-17T13:00:00+00:00 EmrJobFlowSensor 2021-03-17T14:01:09.149086+00:00 2021-03-17T14:11:11.987129+00:00 0:10:02.838043 9801 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-17T14:01:06.771061+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-17T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-17T14:00:30.886810+00:00 2021-03-17T14:00:32.660490+00:00 0:00:01.773680 9800 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-17T14:00:28.728499+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-17T13:00:00+00:00 PythonOperator 2021-03-17T14:00:15.427133+00:00 2021-03-17T14:00:18.251867+00:00 0:00:02.824734 9799 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-17T14:00:12.726956+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-17T12:00:00+00:00 EmrJobFlowSensor 2021-03-17T13:00:43.783744+00:00 2021-03-17T13:06:53.454695+00:00 0:06:09.670951 9797 airflow 3 default 2021-03-17T13:00:41.413279+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-17T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-17T13:00:27.811816+00:00 2021-03-17T13:00:29.525699+00:00 0:00:01.713883 9796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-17T13:00:25.413793+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-17T12:00:00+00:00 PythonOperator 2021-03-17T13:00:11.693440+00:00 2021-03-17T13:00:14.556912+00:00 0:00:02.863472 9795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-17T13:00:09.325354+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-17T12:10:54.380070+00:00 TriggerDagRunOperator 2021-03-17T12:20:53.227216+00:00 2021-03-17T12:20:53.667894+00:00 0:00:00.440678 9793 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T12:20:50.551149+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-17T12:10:54.380070+00:00 TriggerDagRunOperator 2021-03-17T12:20:53.151290+00:00 2021-03-17T12:20:53.733042+00:00 0:00:00.581752 9792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T12:20:50.551119+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-17T12:10:54.380070+00:00 EmrJobFlowSensor 2021-03-17T12:11:37.729850+00:00 2021-03-17T12:20:40.372541+00:00 0:09:02.642691 9791 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-17T12:11:35.464503+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-17T12:10:54.380070+00:00 EmrCreateJobFlowOperator 2021-03-17T12:11:17.758909+00:00 2021-03-17T12:11:19.658338+00:00 0:00:01.899429 9790 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-17T12:11:15.460279+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-17T12:10:54.380070+00:00 PythonOperator 2021-03-17T12:11:01.690558+00:00 2021-03-17T12:11:04.535502+00:00 0:00:02.844944 9789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-17T12:10:59.368852+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-17T11:00:00+00:00 EmrJobFlowSensor 2021-03-17T12:00:56.623086+00:00 9788 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-17T12:00:54.339425+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-17T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-17T12:00:38.541297+00:00 2021-03-17T12:00:40.264157+00:00 0:00:01.722860 9787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-17T12:00:36.261815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-17T11:00:00+00:00 PythonOperator 2021-03-17T12:00:16.502173+00:00 2021-03-17T12:00:19.324844+00:00 0:00:02.822671 9786 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-17T12:00:14.245777+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-17T10:00:00+00:00 TriggerDagRunOperator 2021-03-17T11:57:08.387550+00:00 2021-03-17T11:57:08.934418+00:00 0:00:00.546868 9785 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T11:57:05.948340+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-17T10:00:00+00:00 TriggerDagRunOperator 2021-03-17T11:57:08.217785+00:00 2021-03-17T11:57:08.646286+00:00 0:00:00.428501 9784 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-17T11:57:05.948372+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-17T10:00:00+00:00 EmrJobFlowSensor 2021-03-17T11:46:53.221255+00:00 2021-03-17T11:56:56.045868+00:00 0:10:02.824613 9783 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-17T11:46:50.922969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-17T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-17T11:46:37.141964+00:00 2021-03-17T11:46:38.977144+00:00 0:00:01.835180 9782 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-17T11:46:34.863819+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-17T10:00:00+00:00 PythonOperator 2021-03-17T11:46:21.035992+00:00 2021-03-17T11:46:23.760152+00:00 0:00:02.724160 9781 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-17T11:46:18.854309+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-16T15:09:28.706762+00:00 EmrCreateJobFlowOperator 2021-03-16T15:13:01.159683+00:00 2021-03-16T15:13:02.920602+00:00 0:00:01.760919 9749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-16T15:12:59.296754+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-16T14:00:00+00:00 EmrJobFlowSensor 2021-03-16T15:13:00.889902+00:00 2021-03-16T15:23:03.506121+00:00 0:10:02.616219 9748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-16T15:12:59.296808+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-16T14:00:00+00:00 EmrCreateJobFlowOperator 2021-03-16T15:12:49.226495+00:00 2021-03-16T15:12:50.925229+00:00 0:00:01.698734 9747 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-16T15:12:47.278363+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-16T15:09:28.706762+00:00 PythonOperator 2021-03-16T15:12:48.896146+00:00 2021-03-16T15:12:51.516683+00:00 0:00:02.620537 9746 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-16T15:12:47.278326+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-16T14:00:00+00:00 PythonOperator 2021-03-16T15:12:35.133179+00:00 2021-03-16T15:12:37.949407+00:00 0:00:02.816228 9745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-16T15:12:33.261999+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-16T13:00:00+00:00 EmrCreateJobFlowOperator 2021-03-16T14:00:44.908976+00:00 2021-03-16T14:00:46.569063+00:00 0:00:01.660087 9743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-16T14:00:43.214849+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-16T13:00:00+00:00 PythonOperator 2021-03-16T14:00:32.976665+00:00 2021-03-16T14:00:35.722045+00:00 0:00:02.745380 9742 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-16T14:00:31.203680+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-16T12:00:00+00:00 EmrJobFlowSensor 2021-03-16T13:41:58.742504+00:00 2021-03-16T13:51:01.215437+00:00 0:09:02.472933 9740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-16T13:41:56.988659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-16T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-16T13:41:44.848484+00:00 2021-03-16T13:41:46.636223+00:00 0:00:01.787739 9739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-16T13:41:42.977886+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-16T12:00:00+00:00 PythonOperator 2021-03-16T13:41:32.705179+00:00 2021-03-16T13:41:35.408310+00:00 0:00:02.703131 9738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-16T13:41:30.963580+00:00 2 default_pool