фикс ошибки с etl

This commit is contained in:
2025-12-10 23:23:34 +03:00
parent 409a9f6f31
commit c0bb24764e
+2 -15
View File
@@ -1,18 +1,6 @@
--- a/engine.sql
+++ b/engine.sql
@@ -165,6 +165,11 @@
-- disconnect all previously opened connections
PERFORM dblink_disconnect(unnest(dblink_get_connections()));
+ IF jobs = 1 THEN
+ CALL process_queue(end_date);
+ RETURN;
+ END IF;
+
-- start parallel jobs
FOR i IN 1 .. jobs LOOP
connname := 'job' || i;
@@ -230,7 +235,8 @@
@@ -230,7 +230,8 @@
SELECT count(*) > 0
FROM pg_stat_activity
WHERE application_name = 'Airlines processor'
@@ -20,5 +8,4 @@
+ AND state != 'idle'
+ AND pid <> pg_backend_pid();
END;
/*