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_emr_steps 09-14T23:00:00+00:00 PythonOperator 09-15T23:00:18.947885+00:00 09-15T23:00:19.538756+00:00 0:00:00.590871 604843 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-15T23:00:17.053052+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-13T23:00:00+00:00 EmrJobFlowSensor 09-14T23:01:02.308619+00:00 09-14T23:08:04.083247+00:00 0:07:01.774628 604335 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-14T23:00:58.660104+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-13T23:00:00+00:00 EmrCreateJobFlowOperator 09-14T23:00:38.319507+00:00 09-14T23:00:39.135609+00:00 0:00:00.816102 604333 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-14T23:00:36.494450+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-13T23:00:00+00:00 PythonOperator 09-14T23:00:17.920955+00:00 09-14T23:00:19.101810+00:00 0:00:01.180855 604331 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-14T23:00:14.421410+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-12T23:00:00+00:00 EmrJobFlowSensor 09-13T23:01:02.829642+00:00 09-13T23:09:04.437784+00:00 0:08:01.608142 603836 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-13T23:01:00.842737+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-12T23:00:00+00:00 EmrCreateJobFlowOperator 09-13T23:00:42.828229+00:00 09-13T23:00:43.573693+00:00 0:00:00.745464 603834 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-13T23:00:40.826780+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-12T23:00:00+00:00 PythonOperator 09-13T23:00:24.532493+00:00 09-13T23:00:25.510215+00:00 0:00:00.977722 603831 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-13T23:00:18.873983+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-11T23:00:00+00:00 EmrJobFlowSensor 09-13T01:44:12.436034+00:00 09-13T01:52:14.049551+00:00 0:08:01.613517 603388 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-13T01:44:10.433397+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-11T23:00:00+00:00 EmrCreateJobFlowOperator 09-13T01:43:48.168877+00:00 09-13T01:43:53.364818+00:00 0:00:05.195941 603354 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-13T01:39:56.119944+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-11T23:00:00+00:00 PythonOperator 09-13T01:34:27.471791+00:00 09-13T01:34:36.676665+00:00 0:00:09.204874 603052 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-13T01:32:39.747854+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-10T23:00:00+00:00 EmrJobFlowSensor 09-11T23:01:00.123507+00:00 09-11T23:08:01.796465+00:00 0:07:01.672958 602351 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-11T23:00:56.688509+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-10T23:00:00+00:00 EmrCreateJobFlowOperator 09-11T23:00:38.004586+00:00 09-11T23:00:38.951337+00:00 0:00:00.946751 602349 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-11T23:00:34.675799+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-10T23:00:00+00:00 PythonOperator 09-11T23:00:17.765655+00:00 09-11T23:00:18.655522+00:00 0:00:00.889867 602345 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-11T23:00:14.567833+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-09T23:00:00+00:00 EmrJobFlowSensor 09-10T23:00:56.521296+00:00 09-10T23:07:58.280604+00:00 0:07:01.759308 601849 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-10T23:00:53.302084+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-09T23:00:00+00:00 EmrCreateJobFlowOperator 09-10T23:00:33.242066+00:00 09-10T23:00:33.918210+00:00 0:00:00.676144 601847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-10T23:00:31.355859+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-09T23:00:00+00:00 PythonOperator 09-10T23:00:12.858850+00:00 09-10T23:00:13.393708+00:00 0:00:00.534858 601844 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-10T23:00:11.241471+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-08T23:00:00+00:00 EmrJobFlowSensor 09-09T23:00:58.556646+00:00 09-09T23:09:00.427251+00:00 0:08:01.870605 601342 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-09T23:00:55.148951+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-08T23:00:00+00:00 EmrCreateJobFlowOperator 09-09T23:00:36.694852+00:00 09-09T23:00:38.027339+00:00 0:00:01.332487 601340 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-09T23:00:33.078064+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-08T23:00:00+00:00 PythonOperator 09-09T23:00:18.954430+00:00 09-09T23:00:20.961274+00:00 0:00:02.006844 601337 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-09T23:00:11.075802+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-07T23:00:00+00:00 EmrJobFlowSensor 09-08T23:01:01.182351+00:00 09-08T23:09:03.351434+00:00 0:08:02.169083 600824 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-08T23:00:57.276801+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-07T23:00:00+00:00 EmrCreateJobFlowOperator 09-08T23:00:41.113812+00:00 09-08T23:00:42.321980+00:00 0:00:01.208168 600822 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-08T23:00:37.263185+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-07T23:00:00+00:00 PythonOperator 09-08T23:00:19.697539+00:00 09-08T23:00:21.312302+00:00 0:00:01.614763 600819 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-08T23:00:15.166323+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-06T23:00:00+00:00 EmrJobFlowSensor 09-07T23:01:06.443725+00:00 09-07T23:09:08.232697+00:00 0:08:01.788972 600317 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-07T23:01:03.213869+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-06T23:00:00+00:00 EmrCreateJobFlowOperator 09-07T23:00:44.369710+00:00 09-07T23:00:45.334030+00:00 0:00:00.964320 600314 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-07T23:00:41.192028+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-06T23:00:00+00:00 PythonOperator 09-07T23:00:24.133760+00:00 09-07T23:00:24.999912+00:00 0:00:00.866152 600312 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-07T23:00:19.124732+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-05T23:00:00+00:00 EmrJobFlowSensor 09-06T23:01:07.089604+00:00 09-06T23:08:08.907708+00:00 0:07:01.818104 599804 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-06T23:01:03.609898+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-05T23:00:00+00:00 EmrCreateJobFlowOperator 09-06T23:00:44.815394+00:00 09-06T23:00:45.823502+00:00 0:00:01.008108 599802 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-06T23:00:41.590833+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-05T23:00:00+00:00 PythonOperator 09-06T23:00:23.210077+00:00 09-06T23:00:24.135584+00:00 0:00:00.925507 599800 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-06T23:00:19.526149+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-04T23:00:00+00:00 EmrJobFlowSensor 09-05T23:01:06.030498+00:00 09-05T23:09:08.068771+00:00 0:08:02.038273 599294 airflow-worker-3.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-05T23:01:02.354584+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-04T23:00:00+00:00 EmrCreateJobFlowOperator 09-05T23:00:45.376002+00:00 09-05T23:00:46.901550+00:00 0:00:01.525548 599292 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-05T23:00:40.338655+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-04T23:00:00+00:00 PythonOperator 09-05T23:00:22.395349+00:00 09-05T23:00:23.613409+00:00 0:00:01.218060 599290 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-05T23:00:14.162662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-03T23:00:00+00:00 EmrJobFlowSensor 09-04T23:00:56.862844+00:00 09-04T23:08:58.768341+00:00 0:08:01.905497 598782 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-04T23:00:53.231936+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-03T23:00:00+00:00 EmrCreateJobFlowOperator 09-04T23:00:35.689850+00:00 09-04T23:00:36.820550+00:00 0:00:01.130700 598780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-04T23:00:31.162560+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-03T23:00:00+00:00 PythonOperator 09-04T23:00:12.690488+00:00 09-04T23:00:13.654808+00:00 0:00:00.964320 598776 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-04T23:00:09.105095+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-02T23:00:00+00:00 EmrJobFlowSensor 09-03T23:01:15.197627+00:00 09-03T23:08:17.151162+00:00 0:07:01.953535 598266 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-03T23:01:11.360842+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-02T23:00:00+00:00 EmrCreateJobFlowOperator 09-03T23:00:48.016774+00:00 09-03T23:00:49.179116+00:00 0:00:01.162342 598264 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-03T23:00:43.354823+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-02T23:00:00+00:00 PythonOperator 09-03T23:00:25.970078+00:00 09-03T23:00:27.180371+00:00 0:00:01.210293 598261 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-03T23:00:21.337600+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 09-01T23:00:00+00:00 EmrJobFlowSensor 09-02T23:01:16.034865+00:00 09-02T23:09:17.962899+00:00 0:08:01.928034 597755 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-02T23:01:12.349809+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 09-01T23:00:00+00:00 EmrCreateJobFlowOperator 09-02T23:00:50.719797+00:00 09-02T23:00:51.772782+00:00 0:00:01.052985 597753 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-02T23:00:46.205731+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 09-01T23:00:00+00:00 PythonOperator 09-02T23:00:29.761191+00:00 09-02T23:00:30.849846+00:00 0:00:01.088655 597750 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-02T23:00:26.189679+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-31T23:00:00+00:00 EmrJobFlowSensor 09-01T23:01:09.516737+00:00 09-01T23:09:11.514498+00:00 0:08:01.997761 597244 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 09-01T23:01:05.979614+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-31T23:00:00+00:00 EmrCreateJobFlowOperator 09-01T23:00:43.503845+00:00 09-01T23:00:44.764112+00:00 0:00:01.260267 597242 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 09-01T23:00:39.870582+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-31T23:00:00+00:00 PythonOperator 09-01T23:00:21.225716+00:00 09-01T23:00:22.102615+00:00 0:00:00.876899 597239 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 09-01T23:00:17.750286+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-30T23:00:00+00:00 EmrJobFlowSensor 08-31T23:01:11.226821+00:00 08-31T23:08:12.952835+00:00 0:07:01.726014 596736 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-31T23:01:07.568924+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-30T23:00:00+00:00 EmrCreateJobFlowOperator 08-31T23:00:42.803881+00:00 08-31T23:00:43.836741+00:00 0:00:01.032860 596734 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-31T23:00:39.440832+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-30T23:00:00+00:00 PythonOperator 08-31T23:00:22.184490+00:00 08-31T23:00:23.394650+00:00 0:00:01.210160 596731 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-31T23:00:17.542067+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-29T23:00:00+00:00 EmrJobFlowSensor 08-30T23:01:12.145825+00:00 08-30T23:09:14.188226+00:00 0:08:02.042401 596226 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-30T23:01:08.440256+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-29T23:00:00+00:00 EmrCreateJobFlowOperator 08-30T23:00:50.035921+00:00 08-30T23:00:51.130038+00:00 0:00:01.094117 596224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-30T23:00:46.349469+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-29T23:00:00+00:00 PythonOperator 08-30T23:00:21.846984+00:00 08-30T23:00:22.850731+00:00 0:00:01.003747 596221 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-30T23:00:18.233962+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-28T23:00:00+00:00 EmrJobFlowSensor 08-29T23:01:08.336412+00:00 08-29T23:09:10.043268+00:00 0:08:01.706856 595666 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-29T23:01:05.950349+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-28T23:00:00+00:00 EmrCreateJobFlowOperator 08-29T23:00:47.200336+00:00 08-29T23:00:48.232148+00:00 0:00:01.031812 595664 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-29T23:00:43.807232+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-28T23:00:00+00:00 PythonOperator 08-29T23:00:27.178949+00:00 08-29T23:00:29.044122+00:00 0:00:01.865173 595662 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-29T23:00:23.791265+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-27T23:00:00+00:00 EmrJobFlowSensor 08-28T23:01:25.605768+00:00 08-28T23:08:27.130379+00:00 0:07:01.524611 595159 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-28T23:01:23.357838+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-27T23:00:00+00:00 EmrCreateJobFlowOperator 08-28T23:00:40.240037+00:00 08-28T23:00:41.134974+00:00 0:00:00.894937 595155 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-28T23:00:37.944445+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-27T23:00:00+00:00 PythonOperator 08-28T23:00:20.102982+00:00 08-28T23:00:20.910082+00:00 0:00:00.807100 595152 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-28T23:00:17.854155+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-26T23:00:00+00:00 EmrJobFlowSensor 08-27T23:01:04.492755+00:00 08-27T23:07:06.260427+00:00 0:06:01.767672 594656 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-27T23:01:00.955062+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-26T23:00:00+00:00 EmrCreateJobFlowOperator 08-27T23:00:42.884735+00:00 08-27T23:00:43.576394+00:00 0:00:00.691659 594654 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-27T23:00:40.920465+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-26T23:00:00+00:00 PythonOperator 08-27T23:00:20.600289+00:00 08-27T23:00:21.983095+00:00 0:00:01.382806 594650 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-27T23:00:16.898143+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-25T23:00:00+00:00 EmrJobFlowSensor 08-26T23:00:58.875962+00:00 08-26T23:08:00.818162+00:00 0:07:01.942200 594154 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-26T23:00:54.724869+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-25T23:00:00+00:00 EmrCreateJobFlowOperator 08-26T23:00:33.646160+00:00 08-26T23:00:34.431446+00:00 0:00:00.785286 594152 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-26T23:00:30.757900+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-25T23:00:00+00:00 PythonOperator 08-26T23:00:10.931240+00:00 08-26T23:00:11.575766+00:00 0:00:00.644526 594148 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-26T23:00:08.694033+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-24T23:00:00+00:00 EmrJobFlowSensor 08-25T23:00:50.630456+00:00 08-25T23:07:52.129817+00:00 0:07:01.499361 593670 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-25T23:00:48.692492+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-24T23:00:00+00:00 EmrCreateJobFlowOperator 08-25T23:00:30.815675+00:00 08-25T23:00:31.890242+00:00 0:00:01.074567 593667 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-25T23:00:28.628377+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-24T23:00:00+00:00 PythonOperator 08-25T23:00:04.824997+00:00 08-25T23:00:05.523245+00:00 0:00:00.698248 593663 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-25T23:00:02.618793+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-23T23:00:00+00:00 EmrJobFlowSensor 08-24T23:00:56.285331+00:00 08-24T23:08:58.370475+00:00 0:08:02.085144 593185 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-24T23:00:52.752367+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-23T23:00:00+00:00 EmrCreateJobFlowOperator 08-24T23:00:35.002110+00:00 08-24T23:00:35.844197+00:00 0:00:00.842087 593182 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-24T23:00:32.715131+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-23T23:00:00+00:00 PythonOperator 08-24T23:00:10.290405+00:00 08-24T23:00:11.393334+00:00 0:00:01.102929 593178 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-24T23:00:06.694073+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-22T23:00:00+00:00 EmrJobFlowSensor 08-23T23:01:16.685578+00:00 08-23T23:07:18.515109+00:00 0:06:01.829531 592711 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-23T23:01:12.955662+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-22T23:00:00+00:00 EmrCreateJobFlowOperator 08-23T23:00:54.585977+00:00 08-23T23:00:55.802340+00:00 0:00:01.216363 592708 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-23T23:00:50.949734+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-22T23:00:00+00:00 PythonOperator 08-23T23:00:23.161968+00:00 08-23T23:00:23.809988+00:00 0:00:00.648020 592704 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-23T23:00:20.867010+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-21T23:00:00+00:00 EmrJobFlowSensor 08-22T23:01:11.587736+00:00 08-22T23:09:13.194475+00:00 0:08:01.606739 592226 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-22T23:01:09.315286+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-21T23:00:00+00:00 EmrCreateJobFlowOperator 08-22T23:00:48.145431+00:00 08-22T23:00:49.082957+00:00 0:00:00.937526 592224 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-22T23:00:45.370376+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-21T23:00:00+00:00 PythonOperator 08-22T23:00:28.644440+00:00 08-22T23:00:30.195670+00:00 0:00:01.551230 592222 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-22T23:00:23.343128+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-20T23:00:00+00:00 EmrJobFlowSensor 08-21T23:09:50.088216+00:00 08-21T23:09:50.567122+00:00 0:00:00.478906 591723 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-21T23:09:47.648458+00:00 3 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-20T23:00:00+00:00 EmrCreateJobFlowOperator 08-21T23:00:33.715593+00:00 08-21T23:00:34.519402+00:00 0:00:00.803809 591714 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-21T23:00:31.347927+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-20T23:00:00+00:00 PythonOperator 08-21T23:00:10.345849+00:00 08-21T23:00:11.434663+00:00 0:00:01.088814 591710 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-21T23:00:07.009598+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-19T23:00:00+00:00 EmrJobFlowSensor 08-20T23:00:57.826524+00:00 08-20T23:09:59.588936+00:00 0:09:01.762412 591195 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-20T23:00:55.538871+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-19T23:00:00+00:00 EmrCreateJobFlowOperator 08-20T23:00:37.985898+00:00 08-20T23:00:38.791237+00:00 0:00:00.805339 591193 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-20T23:00:35.430600+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-19T23:00:00+00:00 PythonOperator 08-20T23:00:14.520325+00:00 08-20T23:00:15.364136+00:00 0:00:00.843811 591190 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-20T23:00:11.317396+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-18T23:00:00+00:00 EmrJobFlowSensor 08-19T23:00:57.153233+00:00 08-19T23:08:58.791832+00:00 0:08:01.638599 590637 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-19T23:00:55.037519+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-18T23:00:00+00:00 EmrCreateJobFlowOperator 08-19T23:00:37.240202+00:00 08-19T23:00:38.095268+00:00 0:00:00.855066 590635 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-19T23:00:35.020940+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-18T23:00:00+00:00 PythonOperator 08-19T23:00:09.679273+00:00 08-19T23:00:10.561442+00:00 0:00:00.882169 590631 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-19T23:00:06.941452+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-17T23:00:00+00:00 EmrJobFlowSensor 08-18T23:00:54.304146+00:00 08-18T23:08:56.083826+00:00 0:08:01.779680 590126 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-18T23:00:50.894361+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-17T23:00:00+00:00 EmrCreateJobFlowOperator 08-18T23:00:30.085365+00:00 08-18T23:00:31.008190+00:00 0:00:00.922825 590124 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-18T23:00:26.875714+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-17T23:00:00+00:00 PythonOperator 08-18T23:00:07.035049+00:00 08-18T23:00:07.828737+00:00 0:00:00.793688 590120 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-18T23:00:04.807006+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-16T23:00:00+00:00 EmrJobFlowSensor 08-17T23:01:02.438186+00:00 08-17T23:09:04.362061+00:00 0:08:01.923875 589621 airflow-worker-2.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-17T23:00:59.008988+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-16T23:00:00+00:00 EmrCreateJobFlowOperator 08-17T23:00:39.818355+00:00 08-17T23:00:40.724388+00:00 0:00:00.906033 589619 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-17T23:00:37.143541+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-16T23:00:00+00:00 PythonOperator 08-17T23:00:13.098305+00:00 08-17T23:00:13.847133+00:00 0:00:00.748828 589616 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-17T23:00:10.972202+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-15T23:00:00+00:00 EmrJobFlowSensor 08-16T23:00:59.472963+00:00 08-16T23:09:01.187674+00:00 0:08:01.714711 589117 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-16T23:00:57.324556+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-15T23:00:00+00:00 EmrCreateJobFlowOperator 08-16T23:00:37.448093+00:00 08-16T23:00:38.340065+00:00 0:00:00.891972 589115 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-16T23:00:35.306613+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-15T23:00:00+00:00 PythonOperator 08-16T23:00:12.509049+00:00 08-16T23:00:13.312788+00:00 0:00:00.803739 589112 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-16T23:00:09.283187+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-14T23:00:00+00:00 EmrJobFlowSensor 08-15T23:00:59.627216+00:00 08-15T23:09:01.316629+00:00 0:08:01.689413 588583 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-15T23:00:57.334032+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-14T23:00:00+00:00 EmrCreateJobFlowOperator 08-15T23:00:39.950491+00:00 08-15T23:00:40.798933+00:00 0:00:00.848442 588581 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-15T23:00:37.330373+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-14T23:00:00+00:00 PythonOperator 08-15T23:00:17.978515+00:00 08-15T23:00:18.768219+00:00 0:00:00.789704 588579 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-15T23:00:15.302634+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-13T23:00:00+00:00 EmrJobFlowSensor 08-14T23:01:02.065810+00:00 08-14T23:09:03.779673+00:00 0:08:01.713863 588082 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-14T23:00:59.408974+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-13T23:00:00+00:00 EmrCreateJobFlowOperator 08-14T23:00:39.742799+00:00 08-14T23:00:40.584181+00:00 0:00:00.841382 588080 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-14T23:00:37.399980+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-13T23:00:00+00:00 PythonOperator 08-14T23:00:18.737449+00:00 08-14T23:00:19.547588+00:00 0:00:00.810139 588078 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-14T23:00:15.442150+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 check_cluster_status 08-12T23:00:00+00:00 EmrJobFlowSensor 08-13T23:01:33.433794+00:00 08-13T23:08:34.982548+00:00 0:07:01.548754 587578 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 08-13T23:01:30.694073+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_cluster_and_add_emr_steps 08-12T23:00:00+00:00 EmrCreateJobFlowOperator 08-13T23:00:43.977260+00:00 08-13T23:00:44.860790+00:00 0:00:00.883530 587575 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 2 default 08-13T23:00:41.422135+00:00 2 default_pool
success campaign-delta-past-delete-job_v002 create_emr_steps 08-12T23:00:00+00:00 PythonOperator 08-13T23:00:22.320262+00:00 08-13T23:00:23.032633+00:00 0:00:00.712371 587573 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 08-13T23:00:19.405178+00:00 2 default_pool