From c0bb24764e3d7827b049cd0a6df727da3468c9d1 Mon Sep 17 00:00:00 2001
From: Dmitry Dementev <me@dementev.space>
Date: Wed, 10 Dec 2025 23:23:34 +0300
Subject: [PATCH] =?UTF-8?q?=D1=84=D0=B8=D0=BA=D1=81=20=D0=BE=D1=88=D0=B8?=
 =?UTF-8?q?=D0=B1=D0=BA=D0=B8=20=D1=81=20etl?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 bookings/patches/engine_jobs1_sync.patch | 17 ++---------------
 1 file changed, 2 insertions(+), 15 deletions(-)

diff --git a/bookings/patches/engine_jobs1_sync.patch b/bookings/patches/engine_jobs1_sync.patch
index fa1db5b..6c09c6c 100644
--- a/bookings/patches/engine_jobs1_sync.patch
+++ b/bookings/patches/engine_jobs1_sync.patch
@@ -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;
- 
- /*
+