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

some fixes

Browse source
This commit is contained in:
Fusionshh 2025-10-18 12:11:13 +03:00
parent b8d5881c85
commit b96ddc0111
11 changed files with 23 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

13
mappings/info_recruits/citizen_tables/drivers_licence/parallel/drivers_licence_flow_repeat.hpl
View file

@ -7,6 +7,7 @@
<extended_description/>
<pipeline_version/>
<pipeline_type>Normal</pipeline_type>
<pipeline_status>0</pipeline_status>
<parameters>
</parameters>
<capture_transform_performance>N</capture_transform_performance>
@ -551,21 +552,23 @@ FROM all_data</sql>
<method>none</method>
<schema_name/>
</partitioning>
<compress>N</compress>
<directory>${java.io.tmpdir}</directory>
<prefix/>
<sort_size>1000000</sort_size>
<free_memory/>
<compress>N</compress>
<compress_variable/>
<unique_rows>Y</unique_rows>
<fields>
<field>
<name>recruit_id</name>
<ascending>Y</ascending>
<case_sensitive>N</case_sensitive>
<collator_enabled>N</collator_enabled>
<collator_strength>0</collator_strength>
<name>recruit_id</name>
<presorted>N</presorted>
</field>
</fields>
<sort_prefix>srt</sort_prefix>
<sort_size>1000000</sort_size>
<unique_rows>Y</unique_rows>
<attributes/>
<GUI>
<xloc>720</xloc>

7
mappings/info_recruits/citizen_tables/education/educational_institution_learning/constants/support/check_if_constants_exists.hpl
View file

@ -39,7 +39,6 @@
</partitioning>
<fields>
<field>
<default_value/>
<field_name>constasnts_exists</field_name>
<variable_name>CONSTANTS_EXISTS</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type>
@ -69,11 +68,11 @@
<sql>SELECT EXISTS (
SELECT 1 FROM education_level
UNION ALL
SELECT 1 FROM educational_institution_status
SELECT 1 FROM ervu_dashboard.educational_institution_status
UNION ALL
SELECT 1 FROM minobr_education_speciality
SELECT 1 FROM ervu_dashboard.minobr_education_speciality
UNION ALL
SELECT 1 FROM minprosv_education_speciality
SELECT 1 FROM ervu_dashboard.minprosv_education_speciality
) AS constasnts_exists</sql>
<variables_active>Y</variables_active>
<attributes/>

2
mappings/info_recruits/citizen_tables/education/foreign_diploma/constants/support/check_if_constants_exists.hpl
View file

@ -66,7 +66,7 @@
<execute_each_row>N</execute_each_row>
<limit>0</limit>
<sql>SELECT EXISTS (
SELECT 1 FROM ervu-dashboard.country_oksm
SELECT 1 FROM ervu_dashboard.country_oksm
) AS constasnts_exists</sql>
<variables_active>Y</variables_active>
<attributes/>

5
mappings/info_recruits/citizen_tables/education/russian_diploma/constants/support/check_if_constants_exists.hpl
View file

@ -39,7 +39,6 @@
</partitioning>
<fields>
<field>
<default_value/>
<field_name>constants_exists</field_name>
<variable_name>CONSTANTS_EXISTS</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type>
@ -67,9 +66,9 @@
<execute_each_row>N</execute_each_row>
<limit>0</limit>
<sql>SELECT EXISTS (
SELECT 1 FROM minobr_doc_type
SELECT 1 FROM ervu_dashboard.minobr_doc_type
UNION ALL
SELECT 1 FROM minprosv_doc_type
SELECT 1 FROM ervu_dashboard.minprosv_doc_type
) AS constants_exists</sql>
<variables_active>Y</variables_active>
<attributes/>

2
mappings/info_recruits/citizen_tables/medicine/health_state/constants/support/check_if_constants_exists.hpl
View file

@ -66,7 +66,7 @@
<execute_each_row>N</execute_each_row>
<limit>0</limit>
<sql>SELECT EXISTS (
SELECT 1 FROM ervu-dashboard.disease
SELECT 1 FROM ervu_dashboard.disease
) AS constants_exists</sql>
<variables_active>Y</variables_active>
<attributes/>

2
mappings/info_recruits/citizen_tables/property/recruitment_five_flow_delta.hpl
View file

@ -74,7 +74,7 @@
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

2
mappings/info_recruits/citizen_tables/recruit_archive/recruitment_five_flow_delta.hpl
View file

@ -69,7 +69,7 @@
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

4
mappings/info_recruits/citizen_tables/sport/constants/support/check_if_constants_exists.hpl
View file

@ -66,9 +66,9 @@
<execute_each_row>N</execute_each_row>
<limit>0</limit>
<sql>SELECT EXISTS (
SELECT 1 FROM ervu-dashboard.sport_type
SELECT 1 FROM ervu_dashboard.sport_type
UNION ALL
SELECT 1 FROM ervu-dashboard.russian_region
SELECT 1 FROM ervu_dashboard.russian_region
) AS constasnts_exists</sql>
<variables_active>Y</variables_active>
<attributes/>

2
mappings/info_recruits/citizen_tables/work/employer/parallel/employer_flow_repeat.hpl
View file

@ -357,7 +357,7 @@ SET status = 'PROCESSING',
<method>none</method>
<schema_name/>
</partitioning>
<connection>ervu-dashboard-118</connection>
<connection>ervu-dashboard</connection>
<execute_each_row>N</execute_each_row>
<limit>0</limit>
<sql>with filteredData as (select ri.recruit_id,

1
mappings/info_recruits/citizen_tables/work/work_activity/parallel/work_activity_flow_repeat.hpl
View file

@ -7,6 +7,7 @@
<extended_description/>
<pipeline_version/>
<pipeline_type>Normal</pipeline_type>
<pipeline_status>0</pipeline_status>
<parameters>
</parameters>
<capture_transform_performance>N</capture_transform_performance>

4
mappings/info_recruits/job_general_info_recruits.hwf
View file

@ -136,7 +136,7 @@
<clear_rows>N</clear_rows>
<create_parent_folder>N</create_parent_folder>
<exec_per_row>N</exec_per_row>
<filename>${PROJECT_HOME}/info_recruits/checkpoints/check_status_parallel_recruits_info_citizen.hpl</filename>
<filename>${PROJECT_HOME}/info_recruits/supportive_jobs/check_status_parallel_recruits_info_citizen.hpl</filename>
<loglevel>Basic</loglevel>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
@ -182,7 +182,7 @@
<successwhenvarset>N</successwhenvarset>
<valuetype>variable</valuetype>
<variablename>JOB_PARALLEL_ERROR_EXITS</variablename>
<parallel>Y</parallel>
<parallel>N</parallel>
<xloc>2048</xloc>
<yloc>768</yloc>
<attributes_hac/>