diff --git a/mappings/info_recruits/citizen_tables/citizen/recruitment_five_flow_delta.hpl b/mappings/info_recruits/citizen_tables/citizen/recruitment_five_flow_delta.hpl index d520ca8..d54ae6b 100644 --- a/mappings/info_recruits/citizen_tables/citizen/recruitment_five_flow_delta.hpl +++ b/mappings/info_recruits/citizen_tables/citizen/recruitment_five_flow_delta.hpl @@ -7,7 +7,13 @@ Normal + 0 + + JOB_NAME + citizen_job + + N 1000 @@ -69,14 +75,14 @@ SELECT r.idm_id FROM ervu_dashboard.recruitment r JOIN mud ON mud.recruitment_id = r.idm_id - JOIN recruits_info ri + JOIN ervu_dashboard.recruits_info ri ON COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = r.idm_id AND ri.updated_at > mud.max_upd_date union select r2.idm_id -from recruitment r2 +from ervu_dashboard.recruitment r2 join etl.job_execution je on r2.idm_id = je.recruitment_id where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')