The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

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-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-31T23:00:43.954908+00:00 2021-07-31T23:00:45.601908+00:00 0:00:01.647000 61099 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-31T23:00:41.740037+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-30T23:00:00+00:00 PythonOperator 2021-07-31T23:00:22.379829+00:00 2021-07-31T23:00:26.558868+00:00 0:00:04.179039 61096 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-31T23:00:19.698109+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-29T23:00:00+00:00 EmrJobFlowSensor 2021-07-30T23:00:54.375963+00:00 2021-07-30T23:10:57.386297+00:00 0:10:03.010334 60660 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-30T23:00:51.768578+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-30T23:00:32.399808+00:00 2021-07-30T23:00:34.153334+00:00 0:00:01.753526 60657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-30T23:00:29.760703+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-29T23:00:00+00:00 PythonOperator 2021-07-30T23:00:10.064840+00:00 2021-07-30T23:00:14.705198+00:00 0:00:04.640358 60653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-30T23:00:07.565834+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-28T23:00:00+00:00 EmrJobFlowSensor 2021-07-29T23:01:05.023278+00:00 2021-07-29T23:11:08.145885+00:00 0:10:03.122607 60219 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-29T23:01:02.458134+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-29T23:00:42.504625+00:00 2021-07-29T23:00:44.272957+00:00 0:00:01.768332 60216 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-29T23:00:40.344702+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-28T23:00:00+00:00 PythonOperator 2021-07-29T23:00:18.917891+00:00 2021-07-29T23:00:22.587030+00:00 0:00:03.669139 60213 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-29T23:00:16.356679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-27T23:00:00+00:00 EmrJobFlowSensor 2021-07-28T23:01:05.053714+00:00 2021-07-28T23:11:08.286062+00:00 0:10:03.232348 59779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-28T23:01:02.942926+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-27T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-28T23:00:41.763934+00:00 2021-07-28T23:00:43.483789+00:00 0:00:01.719855 59776 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-28T23:00:38.893386+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-27T23:00:00+00:00 PythonOperator 2021-07-28T23:00:19.313846+00:00 2021-07-28T23:00:22.933854+00:00 0:00:03.620008 59773 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-28T23:00:16.865114+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-26T23:00:00+00:00 EmrJobFlowSensor 2021-07-27T23:00:49.347761+00:00 2021-07-27T23:08:52.063356+00:00 0:08:02.715595 59340 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-27T23:00:47.198640+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-26T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-27T23:00:27.829508+00:00 2021-07-27T23:00:29.559593+00:00 0:00:01.730085 59338 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-27T23:00:25.246677+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-26T23:00:00+00:00 PythonOperator 2021-07-27T23:00:05.724117+00:00 2021-07-27T23:00:09.775546+00:00 0:00:04.051429 59334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-27T23:00:02.891047+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-25T23:00:00+00:00 EmrJobFlowSensor 2021-07-26T23:00:52.854631+00:00 2021-07-26T23:09:55.665162+00:00 0:09:02.810531 58868 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-26T23:00:50.455130+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-25T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-26T23:00:30.569718+00:00 2021-07-26T23:00:32.282123+00:00 0:00:01.712405 58865 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-26T23:00:28.395539+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-25T23:00:00+00:00 PythonOperator 2021-07-26T23:00:08.631348+00:00 2021-07-26T23:00:14.059769+00:00 0:00:05.428421 58862 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-26T23:00:06.348153+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-24T23:00:00+00:00 EmrJobFlowSensor 2021-07-25T23:01:05.761657+00:00 2021-07-25T23:11:08.801506+00:00 0:10:03.039849 58434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-25T23:01:03.256873+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-24T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-25T23:00:43.475883+00:00 2021-07-25T23:00:45.280311+00:00 0:00:01.804428 58432 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-25T23:00:41.169281+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-24T23:00:00+00:00 PythonOperator 2021-07-25T23:00:21.555224+00:00 2021-07-25T23:00:25.220626+00:00 0:00:03.665402 58429 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-25T23:00:19.153247+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-23T23:00:00+00:00 EmrJobFlowSensor 2021-07-24T23:01:01.439012+00:00 2021-07-24T23:11:04.352537+00:00 0:10:02.913525 57997 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-24T23:00:59.056145+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-23T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-24T23:00:41.078546+00:00 2021-07-24T23:00:42.716327+00:00 0:00:01.637781 57995 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-24T23:00:38.954711+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-23T23:00:00+00:00 PythonOperator 2021-07-24T23:00:19.608729+00:00 2021-07-24T23:00:23.226092+00:00 0:00:03.617363 57991 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-24T23:00:16.937492+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-22T23:00:00+00:00 EmrJobFlowSensor 2021-07-23T23:00:58.035183+00:00 2021-07-23T23:09:00.543420+00:00 0:08:02.508237 57560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-23T23:00:55.403261+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-22T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-23T23:00:36.237017+00:00 2021-07-23T23:00:37.887886+00:00 0:00:01.650869 57557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-23T23:00:33.451476+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-22T23:00:00+00:00 PythonOperator 2021-07-23T23:00:14.236881+00:00 2021-07-23T23:00:18.256600+00:00 0:00:04.019719 57554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-23T23:00:11.362175+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-21T23:00:00+00:00 EmrJobFlowSensor 2021-07-22T23:00:56.575811+00:00 2021-07-22T23:10:59.633088+00:00 0:10:03.057277 57122 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-22T23:00:54.417495+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-21T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-22T23:00:36.485356+00:00 2021-07-22T23:00:38.144035+00:00 0:00:01.658679 57119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-22T23:00:34.401394+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-21T23:00:00+00:00 PythonOperator 2021-07-22T23:00:10.561507+00:00 2021-07-22T23:00:16.160368+00:00 0:00:05.598861 57116 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-22T23:00:08.342993+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-20T23:00:00+00:00 EmrJobFlowSensor 2021-07-21T23:00:48.772428+00:00 2021-07-21T23:09:51.618531+00:00 0:09:02.846103 56687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-21T23:00:46.515486+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-20T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-21T23:00:27.235056+00:00 2021-07-21T23:00:29.493928+00:00 0:00:02.258872 56684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-21T23:00:24.474985+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-20T23:00:00+00:00 PythonOperator 2021-07-21T23:00:04.798776+00:00 2021-07-21T23:00:09.951695+00:00 0:00:05.152919 56681 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-21T23:00:02.415419+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-19T23:00:00+00:00 EmrJobFlowSensor 2021-07-20T23:00:57.561629+00:00 2021-07-20T23:10:00.467481+00:00 0:09:02.905852 56251 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-20T23:00:55.416538+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-19T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-20T23:00:35.881011+00:00 2021-07-20T23:00:37.513922+00:00 0:00:01.632911 56248 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-20T23:00:33.466210+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-19T23:00:00+00:00 PythonOperator 2021-07-20T23:00:13.552749+00:00 2021-07-20T23:00:17.436717+00:00 0:00:03.883968 56245 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-20T23:00:11.349930+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-18T23:00:00+00:00 EmrJobFlowSensor 2021-07-19T23:00:56.788336+00:00 2021-07-19T23:08:59.159449+00:00 0:08:02.371113 55815 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-19T23:00:54.187609+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-18T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-19T23:00:34.945171+00:00 2021-07-19T23:00:36.621563+00:00 0:00:01.676392 55812 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-19T23:00:32.155756+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-18T23:00:00+00:00 PythonOperator 2021-07-19T23:00:12.621207+00:00 2021-07-19T23:00:16.687493+00:00 0:00:04.066286 55809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-19T23:00:10.056099+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-17T23:00:00+00:00 EmrJobFlowSensor 2021-07-18T23:00:54.355126+00:00 2021-07-18T23:09:57.043499+00:00 0:09:02.688373 55377 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-18T23:00:51.925370+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-17T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-18T23:00:32.500739+00:00 2021-07-18T23:00:34.324032+00:00 0:00:01.823293 55374 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-18T23:00:30.057091+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-17T23:00:00+00:00 PythonOperator 2021-07-18T23:00:10.381146+00:00 2021-07-18T23:00:14.060553+00:00 0:00:03.679407 55371 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-18T23:00:07.897330+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-16T23:00:00+00:00 EmrJobFlowSensor 2021-07-17T23:01:03.226049+00:00 2021-07-17T23:10:06.185375+00:00 0:09:02.959326 54944 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-17T23:00:59.982267+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-16T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-17T23:00:40.231517+00:00 2021-07-17T23:00:42.060955+00:00 0:00:01.829438 54941 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-17T23:00:37.857548+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-16T23:00:00+00:00 PythonOperator 2021-07-17T23:00:18.689076+00:00 2021-07-17T23:00:22.657025+00:00 0:00:03.967949 54938 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-17T23:00:15.814453+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-15T23:00:00+00:00 EmrJobFlowSensor 2021-07-16T23:00:52.339182+00:00 2021-07-16T23:10:55.319051+00:00 0:10:02.979869 54506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-16T23:00:50.168205+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-16T23:00:30.727532+00:00 2021-07-16T23:00:32.546062+00:00 0:00:01.818530 54503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-16T23:00:27.973080+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-15T23:00:00+00:00 PythonOperator 2021-07-16T23:00:10.896076+00:00 2021-07-16T23:00:14.975295+00:00 0:00:04.079219 54501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-16T23:00:07.846754+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-14T23:00:00+00:00 EmrJobFlowSensor 2021-07-15T23:05:42.573456+00:00 2021-07-15T23:14:45.865141+00:00 0:09:03.291685 54073 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-15T23:05:39.945160+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-14T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-15T23:05:19.980311+00:00 2021-07-15T23:05:21.655039+00:00 0:00:01.674728 54069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-15T23:05:17.790125+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-14T23:00:00+00:00 PythonOperator 2021-07-15T23:05:02.545024+00:00 2021-07-15T23:05:07.012890+00:00 0:00:04.467866 54065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-15T23:04:57.849359+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-13T23:00:00+00:00 EmrJobFlowSensor 2021-07-14T23:02:40.451394+00:00 2021-07-14T23:10:43.050844+00:00 0:08:02.599450 53627 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-14T23:02:38.146332+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-13T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-14T23:02:16.599461+00:00 2021-07-14T23:02:18.353711+00:00 0:00:01.754250 53624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-14T23:02:14.061517+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-13T23:00:00+00:00 PythonOperator 2021-07-14T23:01:54.516382+00:00 2021-07-14T23:01:58.326295+00:00 0:00:03.809913 53619 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-14T23:01:51.958612+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-12T23:00:00+00:00 EmrJobFlowSensor 2021-07-13T23:01:08.619239+00:00 2021-07-13T23:11:11.692900+00:00 0:10:03.073661 53012 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-13T23:01:06.089416+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-13T23:00:48.723607+00:00 2021-07-13T23:00:50.423799+00:00 0:00:01.700192 53010 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-13T23:00:46.032895+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-12T23:00:00+00:00 PythonOperator 2021-07-13T23:00:10.274732+00:00 2021-07-13T23:00:14.048397+00:00 0:00:03.773665 53007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-13T23:00:08.012414+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-11T23:00:00+00:00 EmrJobFlowSensor 2021-07-12T23:01:13.317060+00:00 2021-07-12T23:11:16.046497+00:00 0:10:02.729437 52724 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-12T23:01:11.192546+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-11T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-12T23:00:51.548788+00:00 2021-07-12T23:00:53.181393+00:00 0:00:01.632605 52721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-12T23:00:49.159151+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-11T23:00:00+00:00 PythonOperator 2021-07-12T23:00:11.467673+00:00 2021-07-12T23:00:15.334535+00:00 0:00:03.866862 52717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-12T23:00:09.189452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-10T23:00:00+00:00 EmrJobFlowSensor 2021-07-11T23:01:41.641845+00:00 2021-07-11T23:10:44.724958+00:00 0:09:03.083113 52417 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-11T23:01:39.266953+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-10T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-11T23:01:01.663108+00:00 2021-07-11T23:01:03.375108+00:00 0:00:01.712000 52416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-11T23:00:59.287835+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-10T23:00:00+00:00 PythonOperator 2021-07-11T23:00:22.173271+00:00 2021-07-11T23:00:25.754695+00:00 0:00:03.581424 52414 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-11T23:00:20.034580+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-09T23:00:00+00:00 EmrJobFlowSensor 2021-07-10T23:00:52.528730+00:00 2021-07-10T23:09:55.334443+00:00 0:09:02.805713 52307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-10T23:00:50.375775+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-09T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-10T23:00:30.753403+00:00 2021-07-10T23:00:32.414810+00:00 0:00:01.661407 52305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-10T23:00:28.353451+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-09T23:00:00+00:00 PythonOperator 2021-07-10T23:00:08.666355+00:00 2021-07-10T23:00:12.474370+00:00 0:00:03.808015 52303 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-10T23:00:06.266447+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-08T23:00:00+00:00 EmrJobFlowSensor 2021-07-09T23:00:58.275874+00:00 2021-07-09T23:10:00.939212+00:00 0:09:02.663338 52022 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-09T23:00:56.009093+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-08T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-09T23:00:38.471402+00:00 2021-07-09T23:00:40.151258+00:00 0:00:01.679856 52020 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-09T23:00:36.043515+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-08T23:00:00+00:00 PythonOperator 2021-07-09T23:00:16.648730+00:00 2021-07-09T23:00:20.460507+00:00 0:00:03.811777 52018 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-09T23:00:13.950341+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-07T23:00:00+00:00 EmrJobFlowSensor 2021-07-08T23:00:47.300952+00:00 2021-07-08T23:09:50.117260+00:00 0:09:02.816308 51645 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-08T23:00:45.000627+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-07T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-08T23:00:25.241868+00:00 2021-07-08T23:00:26.902858+00:00 0:00:01.660990 51642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-08T23:00:23.043852+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-07T23:00:00+00:00 PythonOperator 2021-07-08T23:00:05.352686+00:00 2021-07-08T23:00:09.184289+00:00 0:00:03.831603 51639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-08T23:00:02.965338+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-06T23:00:00+00:00 EmrJobFlowSensor 2021-07-07T23:00:51.274255+00:00 2021-07-07T23:09:53.919812+00:00 0:09:02.645557 51211 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-07T23:00:49.031383+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-06T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-07T23:00:29.257426+00:00 2021-07-07T23:00:31.000509+00:00 0:00:01.743083 51207 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-07T23:00:27.010185+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-06T23:00:00+00:00 PythonOperator 2021-07-07T23:00:10.011261+00:00 2021-07-07T23:00:13.729597+00:00 0:00:03.718336 51205 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-07T23:00:06.990015+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-05T23:00:00+00:00 EmrJobFlowSensor 2021-07-06T23:00:55.500822+00:00 2021-07-06T23:08:58.350745+00:00 0:08:02.849923 50763 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-06T23:00:53.244146+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-05T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-06T23:00:27.270199+00:00 2021-07-06T23:00:29.076916+00:00 0:00:01.806717 50760 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-06T23:00:25.120814+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-05T23:00:00+00:00 PythonOperator 2021-07-06T23:00:05.691736+00:00 2021-07-06T23:00:09.765620+00:00 0:00:04.073884 50757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-06T23:00:03.102274+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-04T23:00:00+00:00 EmrJobFlowSensor 2021-07-05T23:00:56.531991+00:00 2021-07-05T23:09:59.659048+00:00 0:09:03.127057 50327 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-05T23:00:54.346867+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-05T23:00:34.540943+00:00 2021-07-05T23:00:36.279342+00:00 0:00:01.738399 50324 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-05T23:00:32.206907+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-04T23:00:00+00:00 PythonOperator 2021-07-05T23:00:12.666889+00:00 2021-07-05T23:00:16.200712+00:00 0:00:03.533823 50321 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-05T23:00:10.185900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-03T23:00:00+00:00 EmrJobFlowSensor 2021-07-04T23:00:48.058845+00:00 2021-07-04T23:10:50.842046+00:00 0:10:02.783201 49873 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-04T23:00:45.413152+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-03T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-04T23:00:26.289773+00:00 2021-07-04T23:00:28.091836+00:00 0:00:01.802063 49870 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-04T23:00:23.464238+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-03T23:00:00+00:00 PythonOperator 2021-07-04T23:00:04.741051+00:00 2021-07-04T23:00:08.526452+00:00 0:00:03.785401 49866 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-04T23:00:01.453838+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-02T23:00:00+00:00 EmrJobFlowSensor 2021-07-03T23:01:06.409186+00:00 2021-07-03T23:10:09.205364+00:00 0:09:02.796178 49438 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-03T23:01:04.183945+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-02T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-03T23:00:44.284399+00:00 2021-07-03T23:00:45.954302+00:00 0:00:01.669903 49435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-03T23:00:42.121684+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-02T23:00:00+00:00 PythonOperator 2021-07-03T23:00:25.535885+00:00 2021-07-03T23:00:29.241788+00:00 0:00:03.705903 49432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-03T23:00:22.154200+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-07-01T23:00:00+00:00 EmrJobFlowSensor 2021-07-02T23:00:49.109916+00:00 2021-07-02T23:10:51.859600+00:00 0:10:02.749684 48998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-02T23:00:46.564424+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-07-01T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-02T23:00:27.319701+00:00 2021-07-02T23:00:29.070014+00:00 0:00:01.750313 48995 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-02T23:00:24.558982+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-07-01T23:00:00+00:00 PythonOperator 2021-07-02T23:00:07.396548+00:00 2021-07-02T23:00:11.218567+00:00 0:00:03.822019 48992 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-02T23:00:04.428118+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-06-30T23:00:00+00:00 EmrJobFlowSensor 2021-07-01T23:00:50.033925+00:00 2021-07-01T23:10:53.048956+00:00 0:10:03.015031 48546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-07-01T23:00:47.753210+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-06-30T23:00:00+00:00 EmrCreateJobFlowOperator 2021-07-01T23:00:30.196711+00:00 2021-07-01T23:00:31.949072+00:00 0:00:01.752361 48543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-07-01T23:00:27.763019+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-06-30T23:00:00+00:00 PythonOperator 2021-07-01T23:00:07.997894+00:00 2021-07-01T23:00:11.735849+00:00 0:00:03.737955 48540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-07-01T23:00:05.611895+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-06-29T23:00:00+00:00 EmrJobFlowSensor 2021-06-30T23:01:06.852313+00:00 2021-06-30T23:11:09.810328+00:00 0:10:02.958015 48122 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-30T23:01:04.661674+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-06-29T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-30T23:00:42.882853+00:00 2021-06-30T23:00:44.589624+00:00 0:00:01.706771 48119 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-30T23:00:40.593106+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-06-29T23:00:00+00:00 PythonOperator 2021-06-30T23:00:18.747764+00:00 2021-06-30T23:00:22.218801+00:00 0:00:03.471037 48116 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-30T23:00:16.503385+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-06-28T23:00:00+00:00 EmrJobFlowSensor 2021-06-29T23:00:52.872175+00:00 2021-06-29T23:10:55.534240+00:00 0:10:02.662065 47827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-29T23:00:50.727744+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-06-28T23:00:00+00:00 EmrCreateJobFlowOperator 2021-06-29T23:00:31.261143+00:00 2021-06-29T23:00:33.018835+00:00 0:00:01.757692 47824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-29T23:00:28.775697+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 2021-06-28T23:00:00+00:00 PythonOperator 2021-06-29T23:00:06.867913+00:00 2021-06-29T23:00:10.302872+00:00 0:00:03.434959 47821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-06-29T23:00:04.688930+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 2021-06-29T08:29:07.388201+00:00 EmrJobFlowSensor 2021-06-29T08:30:03.469871+00:00 2021-06-29T08:40:06.433898+00:00 0:10:02.964027 47616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-06-29T08:30:01.183684+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 2021-06-29T08:29:07.388201+00:00 EmrCreateJobFlowOperator 2021-06-29T08:29:41.271374+00:00 2021-06-29T08:29:42.931617+00:00 0:00:01.660243 47615 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-06-29T08:29:39.156717+00:00 2 default_pool