Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_emr_steps 2021-04-16T09:00:00+00:00 PythonOperator 2021-04-16T10:00:16.217105+00:00 2021-04-16T10:00:19.827939+00:00 0:00:03.610834 17781 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T10:00:13.371996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.771098+00:00 2021-04-16T09:16:54.265723+00:00 0:00:00.494625 17774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752767+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T08:00:00+00:00 TriggerDagRunOperator 2021-04-16T09:16:53.533591+00:00 2021-04-16T09:16:53.957447+00:00 0:00:00.423856 17773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T09:16:50.752810+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T08:00:00+00:00 EmrJobFlowSensor 2021-04-16T09:00:55.214694+00:00 2021-04-16T09:10:58.582057+00:00 0:10:03.367363 17768 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T09:00:53.002200+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T09:00:33.266272+00:00 2021-04-16T09:00:35.106705+00:00 0:00:01.840433 17767 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T09:00:30.983853+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T08:00:00+00:00 PythonOperator 2021-04-16T09:00:11.798761+00:00 2021-04-16T09:00:14.716389+00:00 0:00:02.917628 17766 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T09:00:08.918272+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.727914+00:00 2021-04-16T08:10:59.223895+00:00 0:00:00.495981 17759 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901903+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T07:00:00+00:00 TriggerDagRunOperator 2021-04-16T08:10:58.474251+00:00 2021-04-16T08:10:58.917755+00:00 0:00:00.443504 17758 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T08:10:55.901932+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T07:00:00+00:00 EmrJobFlowSensor 2021-04-16T08:01:07.205950+00:00 2021-04-16T08:10:09.992700+00:00 0:09:02.786750 17753 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T08:01:04.946683+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T08:00:45.121814+00:00 2021-04-16T08:00:47.026331+00:00 0:00:01.904517 17752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T08:00:42.822107+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T07:00:00+00:00 PythonOperator 2021-04-16T08:00:24.976983+00:00 2021-04-16T08:00:27.924646+00:00 0:00:02.947663 17751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T08:00:22.804288+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T06:00:00+00:00 TriggerDagRunOperator 2021-04-16T07:34:31.191495+00:00 2021-04-16T07:34:31.703610+00:00 0:00:00.512115 17744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:34:28.153376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T06:00:00+00:00 TriggerDagRunOperator 2021-04-16T07:34:30.687642+00:00 2021-04-16T07:34:31.130984+00:00 0:00:00.443342 17743 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T07:34:28.153329+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T06:00:00+00:00 EmrJobFlowSensor 2021-04-16T07:11:18.096998+00:00 2021-04-16T07:34:22.897316+00:00 0:23:04.800318 17741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T07:11:15.508291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T07:10:57.926835+00:00 2021-04-16T07:10:59.657572+00:00 0:00:01.730737 17740 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T07:10:55.490833+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T06:00:00+00:00 PythonOperator 2021-04-16T07:10:36.044747+00:00 2021-04-16T07:10:38.991587+00:00 0:00:02.946840 17738 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T07:10:33.456889+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T05:00:00+00:00 TriggerDagRunOperator 2021-04-16T06:10:36.850934+00:00 2021-04-16T06:10:37.365308+00:00 0:00:00.514374 17728 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:10:34.360537+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T05:00:00+00:00 TriggerDagRunOperator 2021-04-16T06:10:36.812613+00:00 2021-04-16T06:10:37.231644+00:00 0:00:00.419031 17727 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T06:10:34.360491+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T05:00:00+00:00 EmrJobFlowSensor 2021-04-16T06:01:09.698155+00:00 2021-04-16T06:10:12.336235+00:00 0:09:02.638080 17723 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T06:01:07.436351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-16T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-16T06:00:45.675235+00:00 2021-04-16T06:00:47.470903+00:00 0:00:01.795668 17722 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-16T06:00:43.358907+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-16T05:00:00+00:00 PythonOperator 2021-04-16T06:00:23.592498+00:00 2021-04-16T06:00:26.814026+00:00 0:00:03.221528 17721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-16T06:00:21.340933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-16T04:00:00+00:00 TriggerDagRunOperator 2021-04-16T05:11:26.661399+00:00 2021-04-16T05:11:27.182112+00:00 0:00:00.520713 17713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:11:24.185045+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-16T04:00:00+00:00 TriggerDagRunOperator 2021-04-16T05:11:26.496549+00:00 2021-04-16T05:11:26.953065+00:00 0:00:00.456516 17712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-16T05:11:24.185014+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-16T04:00:00+00:00 EmrJobFlowSensor 2021-04-16T05:01:05.363143+00:00 2021-04-16T05:11:08.094398+00:00 0:10:02.731255 17708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-16T05:01:03.014615+00:00 2 default_pool
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 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 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 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 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-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 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 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 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 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 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 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 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-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 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
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T20:00:00+00:00 TriggerDagRunOperator 2021-04-15T21:09:16.318609+00:00 2021-04-15T21:09:16.756174+00:00 0:00:00.437565 17593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T21:09:13.689289+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T20:00:00+00:00 TriggerDagRunOperator 2021-04-15T21:09:16.084711+00:00 2021-04-15T21:09:16.647641+00:00 0:00:00.562930 17592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T21:09:13.689320+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T20:00:00+00:00 EmrJobFlowSensor 2021-04-15T21:01:05.157110+00:00 2021-04-15T21:09:07.809707+00:00 0:08:02.652597 17588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T21:01:02.663434+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T21:00:44.794645+00:00 2021-04-15T21:00:46.546882+00:00 0:00:01.752237 17587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T21:00:42.636685+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T20:00:00+00:00 PythonOperator 2021-04-15T21:00:23.112092+00:00 2021-04-15T21:00:26.826038+00:00 0:00:03.713946 17586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T21:00:20.573846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T19:00:00+00:00 TriggerDagRunOperator 2021-04-15T20:11:03.570553+00:00 2021-04-15T20:11:04.090204+00:00 0:00:00.519651 17578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T20:11:00.984018+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T19:00:00+00:00 TriggerDagRunOperator 2021-04-15T20:11:03.174485+00:00 2021-04-15T20:11:03.584487+00:00 0:00:00.410002 17577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T20:11:00.983988+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T19:00:00+00:00 EmrJobFlowSensor 2021-04-15T20:00:50.168202+00:00 2021-04-15T20:10:53.041813+00:00 0:10:02.873611 17573 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T20:00:47.901417+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T20:00:30.297814+00:00 2021-04-15T20:00:31.991902+00:00 0:00:01.694088 17572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T20:00:27.949454+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T19:00:00+00:00 PythonOperator 2021-04-15T20:00:08.169378+00:00 2021-04-15T20:00:11.169940+00:00 0:00:03.000562 17571 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T20:00:05.848824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T18:00:00+00:00 TriggerDagRunOperator 2021-04-15T19:24:16.832157+00:00 2021-04-15T19:24:17.344916+00:00 0:00:00.512759 17564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T19:24:14.123281+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T18:00:00+00:00 TriggerDagRunOperator 2021-04-15T19:24:16.745800+00:00 2021-04-15T19:24:17.137500+00:00 0:00:00.391700 17563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T19:24:14.123254+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T18:00:00+00:00 EmrJobFlowSensor 2021-04-15T19:00:57.746178+00:00 2021-04-15T19:24:02.359339+00:00 0:23:04.613161 17558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T19:00:55.492448+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T19:00:35.592768+00:00 2021-04-15T19:00:38.006064+00:00 0:00:02.413296 17557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T19:00:33.431473+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T18:00:00+00:00 PythonOperator 2021-04-15T19:00:14.930406+00:00 2021-04-15T19:00:18.074262+00:00 0:00:03.143856 17556 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T19:00:11.478423+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T17:00:00+00:00 TriggerDagRunOperator 2021-04-15T18:09:07.932036+00:00 2021-04-15T18:09:08.455749+00:00 0:00:00.523713 17548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T18:09:05.358363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T17:00:00+00:00 TriggerDagRunOperator 2021-04-15T18:09:07.814409+00:00 2021-04-15T18:09:08.218243+00:00 0:00:00.403834 17547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T18:09:05.358324+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T17:00:00+00:00 EmrJobFlowSensor 2021-04-15T18:00:54.753251+00:00 2021-04-15T18:08:57.269916+00:00 0:08:02.516665 17543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T18:00:52.487662+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T18:00:35.400604+00:00 2021-04-15T18:00:37.200995+00:00 0:00:01.800391 17542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T18:00:32.476743+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T17:00:00+00:00 PythonOperator 2021-04-15T18:00:12.697529+00:00 2021-04-15T18:00:15.842111+00:00 0:00:03.144582 17541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T18:00:10.445335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T16:00:00+00:00 TriggerDagRunOperator 2021-04-15T17:10:20.003181+00:00 2021-04-15T17:10:20.740380+00:00 0:00:00.737199 17534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T17:10:17.477376+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T16:00:00+00:00 TriggerDagRunOperator 2021-04-15T17:10:19.883687+00:00 2021-04-15T17:10:20.561132+00:00 0:00:00.677445 17533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T17:10:17.477415+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T16:00:00+00:00 EmrJobFlowSensor 2021-04-15T17:00:48.432931+00:00 2021-04-15T17:09:51.059668+00:00 0:09:02.626737 17528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T17:00:46.248026+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T17:00:26.758942+00:00 2021-04-15T17:00:28.472428+00:00 0:00:01.713486 17527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T17:00:24.228048+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T16:00:00+00:00 PythonOperator 2021-04-15T17:00:04.826642+00:00 2021-04-15T17:00:07.827235+00:00 0:00:03.000593 17526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T17:00:02.264261+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T15:00:00+00:00 TriggerDagRunOperator 2021-04-15T16:10:31.015726+00:00 2021-04-15T16:10:31.544387+00:00 0:00:00.528661 17519 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T16:10:28.544099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T15:00:00+00:00 TriggerDagRunOperator 2021-04-15T16:10:30.887817+00:00 2021-04-15T16:10:31.302058+00:00 0:00:00.414241 17518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T16:10:28.544070+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T15:00:00+00:00 EmrJobFlowSensor 2021-04-15T16:01:03.716405+00:00 2021-04-15T16:10:06.696498+00:00 0:09:02.980093 17513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T16:01:01.462866+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T16:00:41.627719+00:00 2021-04-15T16:00:43.328637+00:00 0:00:01.700918 17512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T16:00:39.416339+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T15:00:00+00:00 PythonOperator 2021-04-15T16:00:19.817571+00:00 2021-04-15T16:00:22.997010+00:00 0:00:03.179439 17511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T16:00:17.394971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T14:00:00+00:00 TriggerDagRunOperator 2021-04-15T15:10:24.925339+00:00 2021-04-15T15:10:25.456746+00:00 0:00:00.531407 17504 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T15:10:22.451950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T14:00:00+00:00 TriggerDagRunOperator 2021-04-15T15:10:24.798456+00:00 2021-04-15T15:10:25.227475+00:00 0:00:00.429019 17503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T15:10:22.451916+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T14:00:00+00:00 EmrJobFlowSensor 2021-04-15T15:00:58.006267+00:00 2021-04-15T15:10:00.809659+00:00 0:09:02.803392 17498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T15:00:55.094010+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T15:00:35.324237+00:00 2021-04-15T15:00:36.995228+00:00 0:00:01.670991 17497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T15:00:33.029797+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-15T14:00:00+00:00 PythonOperator 2021-04-15T15:00:15.439606+00:00 2021-04-15T15:00:18.577852+00:00 0:00:03.138246 17496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-15T15:00:12.913486+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-15T13:00:00+00:00 TriggerDagRunOperator 2021-04-15T14:14:54.833171+00:00 2021-04-15T14:14:55.361749+00:00 0:00:00.528578 17488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T14:14:52.233035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-15T13:00:00+00:00 TriggerDagRunOperator 2021-04-15T14:14:54.822263+00:00 2021-04-15T14:14:55.233809+00:00 0:00:00.411546 17487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-15T14:14:52.233003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-15T13:00:00+00:00 EmrJobFlowSensor 2021-04-15T14:05:44.092025+00:00 2021-04-15T14:14:46.770212+00:00 0:09:02.678187 17485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-15T14:05:41.447481+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-15T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-15T14:05:21.873510+00:00 2021-04-15T14:05:23.718297+00:00 0:00:01.844787 17483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-15T14:05:19.357083+00:00 2 default_pool