fix condition

This commit is contained in:
Fusionshh 2025-11-06 16:40:18 +03:00
parent 4fdb796bb2
commit fff5eeb018

View file

@ -44,7 +44,6 @@
</partitioning> </partitioning>
<fields> <fields>
<field> <field>
<default_value/>
<field_name>exists</field_name> <field_name>exists</field_name>
<variable_name>JOB_PARALLEL_ERROR_EXITS</variable_name> <variable_name>JOB_PARALLEL_ERROR_EXITS</variable_name>
<variable_type>PARENT_WORKFLOW</variable_type> <variable_type>PARENT_WORKFLOW</variable_type>
@ -71,10 +70,18 @@
<connection>ervu-dashboard</connection> <connection>ervu-dashboard</connection>
<execute_each_row>N</execute_each_row> <execute_each_row>N</execute_each_row>
<limit>0</limit> <limit>0</limit>
<sql>SELECT exists(select 1 <sql>SELECT
FROM etl.job_execution EXISTS (
where job_name in ('citizen_job', 'recruits_info_job') SELECT 1
and status in ('ERROR', 'PROCESSING'));</sql> FROM etl.job_execution
WHERE job_name IN ('citizen_job', 'recruits_info_job')
)
AND NOT EXISTS (
SELECT 1
FROM etl.job_execution
WHERE job_name IN ('citizen_job', 'recruits_info_job')
AND status IN ('PROCESSING', 'ERROR')
);</sql>
<variables_active>N</variables_active> <variables_active>N</variables_active>
<attributes/> <attributes/>
<GUI> <GUI>