micord/ervu-dashboard-etl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

some fixes in recruitment_five_flow_delta.hpl

Browse source
This commit is contained in:
Fusionshh 2025-10-17 14:36:40 +03:00
parent 5c46acd614
commit 73bffc3b6e
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
mappings/info_recruits/citizen_tables/citizen/recruitment_five_flow_delta.hpl
View file

@ -7,7 +7,13 @@
<extended_description/> <extended_description/>
<pipeline_version/> <pipeline_version/>
<pipeline_type>Normal</pipeline_type> <pipeline_type>Normal</pipeline_type>
<pipeline_status>0</pipeline_status>
<parameters> <parameters>
<parameter>
<name>JOB_NAME</name>
<default_value>citizen_job</default_value>
<description/>
</parameter>
</parameters> </parameters>
<capture_transform_performance>N</capture_transform_performance> <capture_transform_performance>N</capture_transform_performance>
<transform_performance_capturing_delay>1000</transform_performance_capturing_delay> <transform_performance_capturing_delay>1000</transform_performance_capturing_delay>
@ -69,14 +75,14 @@
SELECT r.idm_id SELECT r.idm_id
FROM ervu_dashboard.recruitment r FROM ervu_dashboard.recruitment r
JOIN mud ON mud.recruitment_id = r.idm_id 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 ON COALESCE(ri.current_recruitment_id, ri.target_recruitment_id) = r.idm_id
AND ri.updated_at > mud.max_upd_date AND ri.updated_at > mud.max_upd_date
union union
select r2.idm_id select r2.idm_id
from recruitment r2 from ervu_dashboard.recruitment r2
join etl.job_execution je join etl.job_execution je
on r2.idm_id = je.recruitment_id on r2.idm_id = je.recruitment_id
where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING') where je.status in ('DELTA_ERROR', 'DELTA_PROCESSING')