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 check_cluster_status 2023-02-16T09:00:00+00:00 EmrJobFlowSensor 2023-02-16T10:03:03.210459+00:00 2023-02-16T10:13:04.923574+00:00 0:10:01.713115 340749 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T10:03:00.909712+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T10:02:41.112061+00:00 2023-02-16T10:02:41.969716+00:00 0:00:00.857655 340747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T10:02:38.887285+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T09:00:00+00:00 PythonOperator 2023-02-16T10:02:21.853364+00:00 2023-02-16T10:02:24.867649+00:00 0:00:03.014285 340745 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T10:02:18.858147+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T08:00:00+00:00 TriggerDagRunOperator 2023-02-16T09:14:56.183914+00:00 2023-02-16T09:14:56.685055+00:00 0:00:00.501141 340734 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T09:14:53.101241+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T08:00:00+00:00 TriggerDagRunOperator 2023-02-16T09:14:55.991118+00:00 2023-02-16T09:14:56.476880+00:00 0:00:00.485762 340733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T09:14:53.101199+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T08:00:00+00:00 EmrJobFlowSensor 2023-02-16T09:02:00.884104+00:00 2023-02-16T09:12:02.846295+00:00 0:10:01.962191 340726 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T09:01:58.483292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T09:01:39.349768+00:00 2023-02-16T09:01:40.170285+00:00 0:00:00.820517 340724 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T09:01:36.518923+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T08:00:00+00:00 PythonOperator 2023-02-16T09:00:12.620848+00:00 2023-02-16T09:00:15.588438+00:00 0:00:02.967590 340721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T09:00:10.134178+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T07:00:00+00:00 TriggerDagRunOperator 2023-02-16T08:12:05.971442+00:00 2023-02-16T08:12:06.577307+00:00 0:00:00.605865 340708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T08:12:03.273734+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T07:00:00+00:00 TriggerDagRunOperator 2023-02-16T08:12:05.870491+00:00 2023-02-16T08:12:06.334189+00:00 0:00:00.463698 340707 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T08:12:03.273705+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T07:00:00+00:00 EmrJobFlowSensor 2023-02-16T08:01:47.458507+00:00 2023-02-16T08:11:49.810791+00:00 0:10:02.352284 340700 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T08:01:44.942379+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T08:01:25.751259+00:00 2023-02-16T08:01:26.639804+00:00 0:00:00.888545 340698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T08:01:22.925453+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T07:00:00+00:00 PythonOperator 2023-02-16T08:00:15.168750+00:00 2023-02-16T08:00:18.109817+00:00 0:00:02.941067 340695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T08:00:12.696083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T06:00:00+00:00 TriggerDagRunOperator 2023-02-16T07:13:41.101918+00:00 2023-02-16T07:13:41.581853+00:00 0:00:00.479935 340683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T07:13:38.334951+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T06:00:00+00:00 TriggerDagRunOperator 2023-02-16T07:13:40.835920+00:00 2023-02-16T07:13:41.306264+00:00 0:00:00.470344 340682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T07:13:38.335000+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T06:00:00+00:00 EmrJobFlowSensor 2023-02-16T07:03:26.690201+00:00 2023-02-16T07:13:28.479226+00:00 0:10:01.789025 340675 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T07:03:24.438245+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T07:03:06.673084+00:00 2023-02-16T07:03:07.556488+00:00 0:00:00.883404 340673 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T07:03:04.402696+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T06:00:00+00:00 PythonOperator 2023-02-16T07:02:45.357966+00:00 2023-02-16T07:02:49.434215+00:00 0:00:04.076249 340671 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T07:02:42.388479+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T05:00:00+00:00 TriggerDagRunOperator 2023-02-16T06:11:23.124641+00:00 2023-02-16T06:11:23.629349+00:00 0:00:00.504708 340658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T06:11:20.688738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T05:00:00+00:00 TriggerDagRunOperator 2023-02-16T06:11:22.893831+00:00 2023-02-16T06:11:23.371790+00:00 0:00:00.477959 340657 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T06:11:20.688702+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T05:00:00+00:00 EmrJobFlowSensor 2023-02-16T06:00:59.464233+00:00 2023-02-16T06:11:01.269081+00:00 0:10:01.804848 340651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T06:00:57.212506+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T06:00:37.389060+00:00 2023-02-16T06:00:38.206663+00:00 0:00:00.817603 340649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T06:00:35.131104+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T05:00:00+00:00 PythonOperator 2023-02-16T06:00:17.493778+00:00 2023-02-16T06:00:21.112641+00:00 0:00:03.618863 340647 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T06:00:15.114269+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T04:00:00+00:00 TriggerDagRunOperator 2023-02-16T05:17:06.589432+00:00 2023-02-16T05:17:07.083194+00:00 0:00:00.493762 340635 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T05:17:03.765201+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T04:00:00+00:00 TriggerDagRunOperator 2023-02-16T05:17:06.487569+00:00 2023-02-16T05:17:06.950626+00:00 0:00:00.463057 340634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T05:17:03.765172+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T04:00:00+00:00 EmrJobFlowSensor 2023-02-16T05:00:50.145678+00:00 2023-02-16T05:10:52.028406+00:00 0:10:01.882728 340626 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T05:00:47.838368+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T05:00:30.187503+00:00 2023-02-16T05:00:31.134505+00:00 0:00:00.947002 340625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T05:00:27.727507+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T04:00:00+00:00 PythonOperator 2023-02-16T05:00:08.501136+00:00 2023-02-16T05:00:11.573555+00:00 0:00:03.072419 340623 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T05:00:05.416683+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T03:00:00+00:00 TriggerDagRunOperator 2023-02-16T04:27:41.149301+00:00 2023-02-16T04:27:41.605818+00:00 0:00:00.456517 340612 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T04:27:38.244610+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T03:00:00+00:00 TriggerDagRunOperator 2023-02-16T04:27:40.918285+00:00 2023-02-16T04:27:41.416416+00:00 0:00:00.498131 340611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T04:27:38.244640+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T03:00:00+00:00 EmrJobFlowSensor 2023-02-16T04:01:07.516976+00:00 2023-02-16T04:11:09.435828+00:00 0:10:01.918852 340604 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T04:01:05.191940+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T04:00:45.400792+00:00 2023-02-16T04:00:46.219791+00:00 0:00:00.818999 340602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T04:00:43.083923+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T03:00:00+00:00 PythonOperator 2023-02-16T04:00:21.694142+00:00 2023-02-16T04:00:24.667740+00:00 0:00:02.973598 340600 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T04:00:19.128073+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T02:00:00+00:00 TriggerDagRunOperator 2023-02-16T03:12:16.705323+00:00 2023-02-16T03:12:17.203819+00:00 0:00:00.498496 340586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T03:12:14.108421+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T02:00:00+00:00 TriggerDagRunOperator 2023-02-16T03:12:16.531268+00:00 2023-02-16T03:12:16.978519+00:00 0:00:00.447251 340585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T03:12:14.108385+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T02:00:00+00:00 EmrJobFlowSensor 2023-02-16T03:00:49.552120+00:00 2023-02-16T03:11:51.556644+00:00 0:11:02.004524 340579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T03:00:47.153376+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T03:00:31.504588+00:00 2023-02-16T03:00:32.326343+00:00 0:00:00.821755 340577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T03:00:27.135763+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T02:00:00+00:00 PythonOperator 2023-02-16T03:00:07.409959+00:00 2023-02-16T03:00:11.228461+00:00 0:00:03.818502 340575 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T03:00:05.097032+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T01:00:00+00:00 TriggerDagRunOperator 2023-02-16T02:11:21.903270+00:00 2023-02-16T02:11:22.443445+00:00 0:00:00.540175 340561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T02:11:19.581943+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T01:00:00+00:00 TriggerDagRunOperator 2023-02-16T02:11:21.782242+00:00 2023-02-16T02:11:22.288206+00:00 0:00:00.505964 340560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T02:11:19.581975+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T01:00:00+00:00 EmrJobFlowSensor 2023-02-16T02:01:01.346699+00:00 2023-02-16T02:11:03.195393+00:00 0:10:01.848694 340554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T02:00:59.005557+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T02:00:41.265305+00:00 2023-02-16T02:00:42.122925+00:00 0:00:00.857620 340552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T02:00:38.986794+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T01:00:00+00:00 PythonOperator 2023-02-16T02:00:19.668716+00:00 2023-02-16T02:00:22.697743+00:00 0:00:03.029027 340550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T02:00:17.016846+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-16T00:00:00+00:00 TriggerDagRunOperator 2023-02-16T01:11:14.633614+00:00 2023-02-16T01:11:15.244978+00:00 0:00:00.611364 340528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T01:11:12.335823+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-16T00:00:00+00:00 TriggerDagRunOperator 2023-02-16T01:11:14.565223+00:00 2023-02-16T01:11:15.099824+00:00 0:00:00.534601 340527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T01:11:12.335864+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-16T00:00:00+00:00 EmrJobFlowSensor 2023-02-16T01:00:54.335643+00:00 2023-02-16T01:10:56.718950+00:00 0:10:02.383307 340520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T01:00:51.936538+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-16T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T01:00:34.160676+00:00 2023-02-16T01:00:34.963810+00:00 0:00:00.803134 340518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T01:00:31.912858+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-16T00:00:00+00:00 PythonOperator 2023-02-16T01:00:13.254366+00:00 2023-02-16T01:00:19.208775+00:00 0:00:05.954409 340516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T01:00:09.894534+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T23:00:00+00:00 TriggerDagRunOperator 2023-02-16T00:11:15.925974+00:00 2023-02-16T00:11:16.470327+00:00 0:00:00.544353 340502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T00:11:13.543604+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T23:00:00+00:00 TriggerDagRunOperator 2023-02-16T00:11:15.708366+00:00 2023-02-16T00:11:16.254931+00:00 0:00:00.546565 340501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-16T00:11:13.543575+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T23:00:00+00:00 EmrJobFlowSensor 2023-02-16T00:01:02.066159+00:00 2023-02-16T00:11:04.014844+00:00 0:10:01.948685 340494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-16T00:00:59.607222+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-16T00:00:39.796005+00:00 2023-02-16T00:00:40.642264+00:00 0:00:00.846259 340492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-16T00:00:37.548807+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T23:00:00+00:00 PythonOperator 2023-02-16T00:00:20.099760+00:00 2023-02-16T00:00:23.971151+00:00 0:00:03.871391 340490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-16T00:00:17.531643+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T22:00:00+00:00 TriggerDagRunOperator 2023-02-15T23:11:19.412202+00:00 2023-02-15T23:11:20.174330+00:00 0:00:00.762128 340475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T23:11:16.632684+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T22:00:00+00:00 TriggerDagRunOperator 2023-02-15T23:11:18.880674+00:00 2023-02-15T23:11:19.864522+00:00 0:00:00.983848 340474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T23:11:16.632711+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T22:00:00+00:00 EmrJobFlowSensor 2023-02-15T23:01:03.790548+00:00 2023-02-15T23:11:05.669889+00:00 0:10:01.879341 340467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T23:01:01.380954+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T23:00:41.736759+00:00 2023-02-15T23:00:42.699578+00:00 0:00:00.962819 340464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T23:00:39.360421+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T22:00:00+00:00 PythonOperator 2023-02-15T23:00:19.923023+00:00 2023-02-15T23:00:26.007010+00:00 0:00:06.083987 340461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T23:00:17.410535+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T21:00:00+00:00 TriggerDagRunOperator 2023-02-15T22:11:04.227736+00:00 2023-02-15T22:11:04.750468+00:00 0:00:00.522732 340446 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T22:11:01.737635+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T21:00:00+00:00 TriggerDagRunOperator 2023-02-15T22:11:04.046001+00:00 2023-02-15T22:11:04.560523+00:00 0:00:00.514522 340445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T22:11:01.737602+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T21:00:00+00:00 EmrJobFlowSensor 2023-02-15T22:00:55.493488+00:00 2023-02-15T22:10:57.395503+00:00 0:10:01.902015 340438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T22:00:53.228983+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T22:00:33.358673+00:00 2023-02-15T22:00:34.172413+00:00 0:00:00.813740 340436 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T22:00:31.139549+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T21:00:00+00:00 PythonOperator 2023-02-15T22:00:13.754855+00:00 2023-02-15T22:00:17.642322+00:00 0:00:03.887467 340434 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T22:00:11.102500+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T20:00:00+00:00 TriggerDagRunOperator 2023-02-15T21:11:19.514292+00:00 2023-02-15T21:11:20.272976+00:00 0:00:00.758684 340420 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T21:11:16.792645+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T20:00:00+00:00 TriggerDagRunOperator 2023-02-15T21:11:19.445361+00:00 2023-02-15T21:11:20.223409+00:00 0:00:00.778048 340419 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T21:11:16.792678+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T20:00:00+00:00 EmrJobFlowSensor 2023-02-15T21:01:03.909572+00:00 2023-02-15T21:11:05.736100+00:00 0:10:01.826528 340412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T21:01:01.548555+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T21:00:43.679682+00:00 2023-02-15T21:00:44.550325+00:00 0:00:00.870643 340411 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T21:00:41.501520+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T20:00:00+00:00 PythonOperator 2023-02-15T21:00:22.429398+00:00 2023-02-15T21:00:25.441690+00:00 0:00:03.012292 340409 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T21:00:19.493445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T19:00:00+00:00 TriggerDagRunOperator 2023-02-15T20:11:20.174197+00:00 2023-02-15T20:11:20.650761+00:00 0:00:00.476564 340394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T20:11:17.500646+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T19:00:00+00:00 TriggerDagRunOperator 2023-02-15T20:11:19.911428+00:00 2023-02-15T20:11:20.403157+00:00 0:00:00.491729 340393 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T20:11:17.500697+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T19:00:00+00:00 EmrJobFlowSensor 2023-02-15T20:00:52.877294+00:00 2023-02-15T20:10:54.576844+00:00 0:10:01.699550 340386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T20:00:50.590235+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T20:00:32.955811+00:00 2023-02-15T20:00:33.902322+00:00 0:00:00.946511 340384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T20:00:30.562542+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T19:00:00+00:00 PythonOperator 2023-02-15T20:00:11.290290+00:00 2023-02-15T20:00:15.133389+00:00 0:00:03.843099 340382 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T20:00:08.597984+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T18:00:00+00:00 TriggerDagRunOperator 2023-02-15T19:11:03.202019+00:00 2023-02-15T19:11:03.706914+00:00 0:00:00.504895 340368 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T19:11:00.615351+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T18:00:00+00:00 TriggerDagRunOperator 2023-02-15T19:11:02.931391+00:00 2023-02-15T19:11:03.442356+00:00 0:00:00.510965 340367 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T19:11:00.615399+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T18:00:00+00:00 EmrJobFlowSensor 2023-02-15T19:00:46.404357+00:00 2023-02-15T19:10:48.097483+00:00 0:10:01.693126 340360 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T19:00:43.678283+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T19:00:25.874338+00:00 2023-02-15T19:00:26.695861+00:00 0:00:00.821523 340358 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T19:00:23.659519+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T18:00:00+00:00 PythonOperator 2023-02-15T19:00:04.313947+00:00 2023-02-15T19:00:07.248604+00:00 0:00:02.934657 340356 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T19:00:01.645996+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T17:00:00+00:00 TriggerDagRunOperator 2023-02-15T18:11:04.385493+00:00 2023-02-15T18:11:04.874235+00:00 0:00:00.488742 340342 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T18:11:01.609461+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T17:00:00+00:00 TriggerDagRunOperator 2023-02-15T18:11:04.222273+00:00 2023-02-15T18:11:04.686272+00:00 0:00:00.463999 340341 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T18:11:01.609510+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T17:00:00+00:00 EmrJobFlowSensor 2023-02-15T18:00:56.775542+00:00 2023-02-15T18:10:58.456472+00:00 0:10:01.680930 340334 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T18:00:54.600358+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T17:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T18:00:36.864692+00:00 2023-02-15T18:00:37.693487+00:00 0:00:00.828795 340332 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T18:00:34.581085+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T17:00:00+00:00 PythonOperator 2023-02-15T18:00:15.013875+00:00 2023-02-15T18:00:18.876926+00:00 0:00:03.863051 340330 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T18:00:12.568011+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T16:00:00+00:00 TriggerDagRunOperator 2023-02-15T17:11:16.616058+00:00 2023-02-15T17:11:17.187764+00:00 0:00:00.571706 340316 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T17:11:14.337273+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T16:00:00+00:00 TriggerDagRunOperator 2023-02-15T17:11:16.530340+00:00 2023-02-15T17:11:17.114468+00:00 0:00:00.584128 340315 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T17:11:14.337240+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T16:00:00+00:00 EmrJobFlowSensor 2023-02-15T17:00:54.674088+00:00 2023-02-15T17:10:56.506108+00:00 0:10:01.832020 340309 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T17:00:51.999374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T16:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T17:00:32.455884+00:00 2023-02-15T17:00:33.303360+00:00 0:00:00.847476 340307 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T17:00:29.987196+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T16:00:00+00:00 PythonOperator 2023-02-15T17:00:12.146211+00:00 2023-02-15T17:00:15.968228+00:00 0:00:03.822017 340305 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T17:00:09.864506+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T15:00:00+00:00 TriggerDagRunOperator 2023-02-15T16:11:12.530058+00:00 2023-02-15T16:11:13.096817+00:00 0:00:00.566759 340293 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T16:11:10.215330+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T15:00:00+00:00 TriggerDagRunOperator 2023-02-15T16:11:12.414061+00:00 2023-02-15T16:11:12.881018+00:00 0:00:00.466957 340292 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T16:11:10.215293+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T15:00:00+00:00 EmrJobFlowSensor 2023-02-15T16:01:02.521886+00:00 2023-02-15T16:11:04.477832+00:00 0:10:01.955946 340286 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T16:01:00.238658+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T15:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T16:00:40.617475+00:00 2023-02-15T16:00:41.460410+00:00 0:00:00.842935 340284 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T16:00:38.204163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T15:00:00+00:00 PythonOperator 2023-02-15T16:00:19.495835+00:00 2023-02-15T16:00:22.418013+00:00 0:00:02.922178 340282 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T16:00:16.207494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T14:00:00+00:00 TriggerDagRunOperator 2023-02-15T15:22:32.424279+00:00 2023-02-15T15:22:32.916385+00:00 0:00:00.492106 340271 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T15:22:29.729053+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T14:00:00+00:00 TriggerDagRunOperator 2023-02-15T15:22:32.238327+00:00 2023-02-15T15:22:32.702576+00:00 0:00:00.464249 340270 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T15:22:29.729025+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-15T14:00:00+00:00 EmrJobFlowSensor 2023-02-15T15:12:14.029915+00:00 2023-02-15T15:22:15.908127+00:00 0:10:01.878212 340267 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-15T15:12:11.166142+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-15T14:00:00+00:00 EmrCreateJobFlowOperator 2023-02-15T15:11:51.352504+00:00 2023-02-15T15:11:52.226624+00:00 0:00:00.874120 340263 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-15T15:11:49.150386+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-15T14:00:00+00:00 PythonOperator 2023-02-15T15:11:31.588332+00:00 2023-02-15T15:11:34.796675+00:00 0:00:03.208343 340261 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-15T15:11:29.106599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-15T13:00:00+00:00 TriggerDagRunOperator 2023-02-15T14:22:35.283245+00:00 2023-02-15T14:22:35.788943+00:00 0:00:00.505698 340248 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T14:22:31.994563+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-15T13:00:00+00:00 TriggerDagRunOperator 2023-02-15T14:22:34.909464+00:00 2023-02-15T14:22:35.513723+00:00 0:00:00.604259 340247 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-15T14:22:31.994516+00:00 2 default_pool