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

  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_cluster_and_add_emr_steps 2021-04-16T04:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T05:00:43.221969+00:00 2021-04-16T05:00:45.086684+00:00 0:00:01.864715 17707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T05:00:40.994202+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T04:00:00+00:00 PythonOperator 2021-04-16T05:00:21.394513+00:00 2021-04-16T05:00:24.354182+00:00 0:00:02.959669 17706 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T05:00:18.958321+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:10:16.644508+00:00 2021-04-16T04:19:19.500343+00:00 0:09:02.855835 17704 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:10:14.263554+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:10:04.854747+00:00 2021-04-16T04:19:07.692329+00:00 0:09:02.837582 17703 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:10:02.193035+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:09:54.419986+00:00 2021-04-16T04:09:56.091862+00:00 0:00:01.671876 17702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:09:52.186126+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:09:42.313831+00:00 2021-04-16T04:09:44.157343+00:00 0:00:01.843512 17701 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:09:40.126870+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:09:34.914716+00:00 2021-04-16T04:09:38.117143+00:00 0:00:03.202427 17700 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:09:32.120660+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:09:22.486956+00:00 2021-04-16T04:09:25.421582+00:00 0:00:02.934626 17699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:09:20.108142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T03:00:00+00:00 TriggerDagRunOperator 2021-04-16T04:09:16.424293+00:00 2021-04-16T04:09:17.159084+00:00 0:00:00.734791 17698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:09:14.103440+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T03:00:00+00:00 TriggerDagRunOperator 2021-04-16T04:09:16.271783+00:00 2021-04-16T04:09:17.007909+00:00 0:00:00.736126 17697 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:09:14.103406+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T03:05:00+00:00 EmrJobFlowSensor 2021-04-16T04:05:56.089345+00:00 2021-04-16T04:14:58.584469+00:00 0:09:02.495124 17696 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T04:05:53.863560+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:05:36.271176+00:00 2021-04-16T04:05:38.014052+00:00 0:00:01.742876 17695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T04:05:33.877991+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T03:05:00+00:00 PythonOperator 2021-04-16T04:05:13.885217+00:00 2021-04-16T04:05:16.768149+00:00 0:00:02.882932 17694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:05:11.751850+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T03:00:00+00:00 EmrJobFlowSensor 2021-04-16T04:00:53.558776+00:00 2021-04-16T04:08:56.026643+00:00 0:08:02.467867 17693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T04:00:51.361838+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T04:00:33.509796+00:00 2021-04-16T04:00:35.344338+00:00 0:00:01.834542 17692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T04:00:31.287234+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T03:00:00+00:00 PythonOperator 2021-04-16T04:00:11.592735+00:00 2021-04-16T04:00:14.552427+00:00 0:00:02.959692 17691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T04:00:09.216378+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:11:20.285192+00:00 2021-04-16T03:21:22.995854+00:00 0:10:02.710662 17689 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:11:17.968834+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:11:04.477231+00:00 2021-04-16T03:20:07.438981+00:00 0:09:02.961750 17688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:11:01.894789+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:10:49.992893+00:00 2021-04-16T03:10:51.653575+00:00 0:00:01.660682 17687 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:10:47.828605+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:10:38.317323+00:00 2021-04-16T03:10:40.094374+00:00 0:00:01.777051 17686 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:10:35.818933+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:10:26.042298+00:00 2021-04-16T03:10:29.210831+00:00 0:00:03.168533 17685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:10:23.808831+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:10:18.294954+00:00 2021-04-16T03:10:21.210056+00:00 0:00:02.915102 17684 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:10:15.796250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T02:00:00+00:00 TriggerDagRunOperator 2021-04-16T03:10:06.147057+00:00 2021-04-16T03:10:06.671036+00:00 0:00:00.523979 17683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:10:03.786565+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T02:00:00+00:00 TriggerDagRunOperator 2021-04-16T03:10:05.981376+00:00 2021-04-16T03:10:06.402020+00:00 0:00:00.420644 17682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:10:03.786535+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T02:05:00+00:00 EmrJobFlowSensor 2021-04-16T03:05:59.910506+00:00 2021-04-16T03:15:02.873553+00:00 0:09:02.963047 17681 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T03:05:57.398079+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:05:37.715873+00:00 2021-04-16T03:05:39.492724+00:00 0:00:01.776851 17680 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T03:05:35.377012+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T02:05:00+00:00 PythonOperator 2021-04-16T03:05:17.831475+00:00 2021-04-16T03:05:20.678371+00:00 0:00:02.846896 17679 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:05:15.368347+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T02:00:00+00:00 EmrJobFlowSensor 2021-04-16T03:00:49.230799+00:00 2021-04-16T03:09:51.817612+00:00 0:09:02.586813 17678 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T03:00:46.805590+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T03:00:26.889239+00:00 2021-04-16T03:00:28.608375+00:00 0:00:01.719136 17677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T03:00:24.783407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T02:00:00+00:00 PythonOperator 2021-04-16T03:00:05.367824+00:00 2021-04-16T03:00:08.341043+00:00 0:00:02.973219 17676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T03:00:02.765674+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T01:00:00+00:00 EmrJobFlowSensor 2021-04-16T02:11:24.869458+00:00 2021-04-16T02:20:27.448518+00:00 0:09:02.579060 17674 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:11:22.102411+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T01:00:00+00:00 EmrJobFlowSensor 2021-04-16T02:11:22.515087+00:00 2021-04-16T02:21:25.648117+00:00 0:10:03.133030 17673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:11:20.140630+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T02:11:04.418182+00:00 2021-04-16T02:11:06.197825+00:00 0:00:01.779643 17672 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T02:11:02.085029+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T02:11:00.550431+00:00 2021-04-16T02:11:02.293277+00:00 0:00:01.742846 17671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T02:10:58.066240+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T01:00:00+00:00 PythonOperator 2021-04-16T02:10:42.569733+00:00 2021-04-16T02:10:45.513577+00:00 0:00:02.943844 17670 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T02:10:39.959017+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T01:00:00+00:00 PythonOperator 2021-04-16T02:10:40.239235+00:00 2021-04-16T02:10:43.714131+00:00 0:00:03.474896 17669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T02:10:37.936623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T01:00:00+00:00 TriggerDagRunOperator 2021-04-16T02:10:24.578724+00:00 2021-04-16T02:10:25.137955+00:00 0:00:00.559231 17668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:10:21.975971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T01:00:00+00:00 TriggerDagRunOperator 2021-04-16T02:10:24.431713+00:00 2021-04-16T02:10:24.845034+00:00 0:00:00.413321 17667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:10:21.976011+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T01:05:00+00:00 EmrJobFlowSensor 2021-04-16T02:06:03.718043+00:00 2021-04-16T02:14:06.193536+00:00 0:08:02.475493 17666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T02:06:01.511093+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T02:05:41.804813+00:00 2021-04-16T02:05:43.448038+00:00 0:00:01.643225 17665 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T02:05:39.557158+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T01:05:00+00:00 PythonOperator 2021-04-16T02:05:19.757027+00:00 2021-04-16T02:05:22.617954+00:00 0:00:02.860927 17664 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T02:05:17.485461+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T01:00:00+00:00 EmrJobFlowSensor 2021-04-16T02:01:05.543364+00:00 2021-04-16T02:10:08.370098+00:00 0:09:02.826734 17663 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T02:01:03.204800+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T02:00:43.366801+00:00 2021-04-16T02:00:45.493321+00:00 0:00:02.126520 17662 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T02:00:41.150916+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T01:00:00+00:00 PythonOperator 2021-04-16T02:00:23.707737+00:00 2021-04-16T02:00:26.830888+00:00 0:00:03.123151 17661 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T02:00:21.123505+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-16T00:00:00+00:00 EmrJobFlowSensor 2021-04-16T01:10:04.531647+00:00 2021-04-16T01:20:07.868379+00:00 0:10:03.336732 17659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T01:10:02.072138+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-16T00:00:00+00:00 EmrJobFlowSensor 2021-04-16T01:10:00.870980+00:00 2021-04-16T01:32:05.190943+00:00 0:22:04.319963 17658 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T01:09:58.073963+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-16T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T01:09:42.819568+00:00 2021-04-16T01:09:44.672577+00:00 0:00:01.853009 17657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T01:09:39.989575+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-16T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T01:09:40.545435+00:00 2021-04-16T01:09:42.729621+00:00 0:00:02.184186 17656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T01:09:38.052265+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-16T00:00:00+00:00 PythonOperator 2021-04-16T01:09:20.218626+00:00 2021-04-16T01:09:23.343540+00:00 0:00:03.124914 17655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T01:09:17.958162+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-16T00:00:00+00:00 PythonOperator 2021-04-16T01:09:18.164617+00:00 2021-04-16T01:09:21.027639+00:00 0:00:02.863022 17654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T01:09:15.948094+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T00:00:00+00:00 TriggerDagRunOperator 2021-04-16T01:09:00.550120+00:00 2021-04-16T01:09:00.973518+00:00 0:00:00.423398 17653 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T01:08:57.972812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T00:00:00+00:00 TriggerDagRunOperator 2021-04-16T01:09:00.504051+00:00 2021-04-16T01:09:01.039311+00:00 0:00:00.535260 17652 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T01:08:57.972923+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-16T00:05:00+00:00 EmrJobFlowSensor 2021-04-16T01:05:57.954941+00:00 2021-04-16T01:15:00.564611+00:00 0:09:02.609670 17651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T01:05:55.661272+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-16T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T01:05:35.956186+00:00 2021-04-16T01:05:37.579536+00:00 0:00:01.623350 17650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T01:05:33.592802+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-16T00:05:00+00:00 PythonOperator 2021-04-16T01:05:15.763471+00:00 2021-04-16T01:05:18.683880+00:00 0:00:02.920409 17649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T01:05:13.545820+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T00:00:00+00:00 EmrJobFlowSensor 2021-04-16T01:00:47.304873+00:00 2021-04-16T01:08:49.801983+00:00 0:08:02.497110 17648 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T01:00:45.080823+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T01:00:27.230225+00:00 2021-04-16T01:00:28.975502+00:00 0:00:01.745277 17647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T01:00:25.016407+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T00:00:00+00:00 PythonOperator 2021-04-16T01:00:06.011846+00:00 2021-04-16T01:00:09.069573+00:00 0:00:03.057727 17646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T01:00:03.057753+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T23:00:00+00:00 EmrJobFlowSensor 2021-04-16T00:13:13.440408+00:00 2021-04-16T00:23:16.229322+00:00 0:10:02.788914 17644 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T00:13:10.789251+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T23:00:00+00:00 EmrJobFlowSensor 2021-04-16T00:13:11.132391+00:00 2021-04-16T00:22:14.103074+00:00 0:09:02.970683 17643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T00:13:08.846619+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T00:12:51.079286+00:00 2021-04-16T00:12:52.817435+00:00 0:00:01.738149 17642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T00:12:48.726872+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T00:12:51.023804+00:00 2021-04-16T00:12:52.871952+00:00 0:00:01.848148 17641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T00:12:48.726819+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T23:00:00+00:00 PythonOperator 2021-04-16T00:12:31.023627+00:00 2021-04-16T00:12:34.223896+00:00 0:00:03.200269 17640 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T00:12:28.709768+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T23:00:00+00:00 PythonOperator 2021-04-16T00:12:29.220745+00:00 2021-04-16T00:12:32.078063+00:00 0:00:02.857318 17639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T00:12:26.708655+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T23:00:00+00:00 TriggerDagRunOperator 2021-04-16T00:12:17.208435+00:00 2021-04-16T00:12:17.734965+00:00 0:00:00.526530 17638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T00:12:14.696113+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T23:00:00+00:00 TriggerDagRunOperator 2021-04-16T00:12:17.126138+00:00 2021-04-16T00:12:17.564457+00:00 0:00:00.438319 17637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T00:12:14.696152+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T23:05:00+00:00 EmrJobFlowSensor 2021-04-16T00:06:04.905918+00:00 2021-04-16T00:15:07.724058+00:00 0:09:02.818140 17636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T00:06:02.249011+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-16T00:05:42.629056+00:00 2021-04-16T00:05:44.266024+00:00 0:00:01.636968 17635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-16T00:05:40.156563+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T23:05:00+00:00 PythonOperator 2021-04-16T00:05:22.289285+00:00 2021-04-16T00:05:25.257521+00:00 0:00:02.968236 17634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T00:05:20.083512+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T23:00:00+00:00 EmrJobFlowSensor 2021-04-16T00:01:03.954923+00:00 2021-04-16T00:12:06.787095+00:00 0:11:02.832172 17633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T00:01:01.684261+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T00:00:41.815298+00:00 2021-04-16T00:00:43.696054+00:00 0:00:01.880756 17632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T00:00:39.594210+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T23:00:00+00:00 PythonOperator 2021-04-16T00:00:20.011879+00:00 2021-04-16T00:00:23.240955+00:00 0:00:03.229076 17631 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T00:00:17.585132+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T22:00:00+00:00 EmrJobFlowSensor 2021-04-15T23:24:01.566900+00:00 2021-04-15T23:34:04.361926+00:00 0:10:02.795026 17629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T23:23:58.774196+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T23:23:38.911723+00:00 2021-04-15T23:23:40.585441+00:00 0:00:01.673718 17628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T23:23:36.697652+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T22:00:00+00:00 EmrJobFlowSensor 2021-04-15T23:22:26.986637+00:00 2021-04-15T23:31:29.720578+00:00 0:09:02.733941 17627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T23:22:24.606282+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T22:00:00+00:00 PythonOperator 2021-04-15T23:22:12.289225+00:00 2021-04-15T23:22:15.646265+00:00 0:00:03.357040 17626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T23:22:08.594051+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T23:21:58.912202+00:00 2021-04-15T23:22:00.602320+00:00 0:00:01.690118 17625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T23:21:56.646422+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T22:00:00+00:00 PythonOperator 2021-04-15T23:21:28.796448+00:00 2021-04-15T23:21:31.715279+00:00 0:00:02.918831 17624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T23:21:26.525936+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T22:00:00+00:00 TriggerDagRunOperator 2021-04-15T23:21:03.082793+00:00 2021-04-15T23:21:03.511734+00:00 0:00:00.428941 17623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T23:21:00.506047+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T22:00:00+00:00 TriggerDagRunOperator 2021-04-15T23:21:02.838592+00:00 2021-04-15T23:21:03.378073+00:00 0:00:00.539481 17622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T23:21:00.506018+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T22:05:00+00:00 EmrJobFlowSensor 2021-04-15T23:05:47.582341+00:00 2021-04-15T23:14:50.142185+00:00 0:09:02.559844 17621 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T23:05:45.251143+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T23:05:25.327522+00:00 2021-04-15T23:05:26.983681+00:00 0:00:01.656159 17620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T23:05:23.152474+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T22:05:00+00:00 PythonOperator 2021-04-15T23:05:05.370830+00:00 2021-04-15T23:05:08.344816+00:00 0:00:02.973986 17619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T23:05:03.136543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T22:00:00+00:00 EmrJobFlowSensor 2021-04-15T23:00:48.971603+00:00 2021-04-15T23:20:53.007160+00:00 0:20:04.035557 17618 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T23:00:46.693291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T23:00:26.866067+00:00 2021-04-15T23:00:28.698304+00:00 0:00:01.832237 17617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T23:00:24.635051+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T22:00:00+00:00 PythonOperator 2021-04-15T23:00:07.082129+00:00 2021-04-15T23:00:09.968123+00:00 0:00:02.885994 17616 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T23:00:04.731451+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-15T21:00:00+00:00 EmrJobFlowSensor 2021-04-15T22:11:32.929774+00:00 2021-04-15T22:20:35.482181+00:00 0:09:02.552407 17614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T22:11:30.500397+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-15T21:00:00+00:00 EmrJobFlowSensor 2021-04-15T22:11:20.776621+00:00 2021-04-15T22:20:23.643193+00:00 0:09:02.866572 17613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T22:11:18.491233+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-15T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T22:11:12.759043+00:00 2021-04-15T22:11:14.574218+00:00 0:00:01.815175 17612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T22:11:10.483648+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-15T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T22:10:54.796827+00:00 2021-04-15T22:10:56.469152+00:00 0:00:01.672325 17611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T22:10:52.438222+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-15T21:00:00+00:00 PythonOperator 2021-04-15T22:10:38.829316+00:00 2021-04-15T22:10:41.735148+00:00 0:00:02.905832 17610 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T22:10:36.431899+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-15T21:00:00+00:00 PythonOperator 2021-04-15T22:10:25.103609+00:00 2021-04-15T22:10:28.188013+00:00 0:00:03.084404 17609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T22:10:22.412651+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T21:00:00+00:00 TriggerDagRunOperator 2021-04-15T22:10:14.884954+00:00 2021-04-15T22:10:15.415074+00:00 0:00:00.530120 17608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T22:10:12.402939+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T21:00:00+00:00 TriggerDagRunOperator 2021-04-15T22:10:14.740991+00:00 2021-04-15T22:10:15.189888+00:00 0:00:00.448897 17607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T22:10:12.402902+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-15T21:05:00+00:00 EmrJobFlowSensor 2021-04-15T22:05:58.262423+00:00 2021-04-15T22:15:00.787636+00:00 0:09:02.525213 17606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T22:05:56.105242+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-15T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-15T22:05:38.482099+00:00 2021-04-15T22:05:40.265526+00:00 0:00:01.783427 17605 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-15T22:05:36.089807+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-15T21:05:00+00:00 PythonOperator 2021-04-15T22:05:16.312092+00:00 2021-04-15T22:05:19.240762+00:00 0:00:02.928670 17604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T22:05:14.069650+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T21:00:00+00:00 EmrJobFlowSensor 2021-04-15T22:00:47.603705+00:00 2021-04-15T22:09:50.254344+00:00 0:09:02.650639 17603 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T22:00:45.389817+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T22:00:27.536799+00:00 2021-04-15T22:00:29.276475+00:00 0:00:01.739676 17602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T22:00:25.327052+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T21:00:00+00:00 PythonOperator 2021-04-15T22:00:05.734345+00:00 2021-04-15T22:00:09.379105+00:00 0:00:03.644760 17601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T22:00:03.307666+00:00 2 default_pool