From 5fed8f4c06a5e392c02cd14f99efe9318377c08e Mon Sep 17 00:00:00 2001 From: Alessandro Date: Tue, 24 Mar 2026 17:37:54 +0100 Subject: [PATCH 1/6] fix(HOT): don't write on cstore on track_response --- extensions/business/mixins/request_tracking_mixin.py | 2 -- ver.py | 2 +- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/extensions/business/mixins/request_tracking_mixin.py b/extensions/business/mixins/request_tracking_mixin.py index 9c6e710f..11f00441 100644 --- a/extensions/business/mixins/request_tracking_mixin.py +++ b/extensions/business/mixins/request_tracking_mixin.py @@ -82,8 +82,6 @@ def _track_response(self, method, response): break except Exception as e: self.P(f"Error tracking response in cstore: {e}", color='r') - if self.__rt_dirty: - self.__rt_save() return def __rt_save(self): diff --git a/ver.py b/ver.py index 461e39d0..76c9b773 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.130' +__VER__ = '2.10.131' From ddd750874d546e167abe8bb65b32f168f50601b8 Mon Sep 17 00:00:00 2001 From: Cristi Bleotiu Date: Tue, 24 Mar 2026 20:33:29 +0200 Subject: [PATCH 2/6] fix: temporary disabled cstore request tracking for dauth_manager.py --- ver.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ver.py b/ver.py index 76c9b773..5852fb6b 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.131' +__VER__ = '2.10.132' From 857860c15dbdc03bca0baed50af06315a3ea681e Mon Sep 17 00:00:00 2001 From: Cristi Bleotiu Date: Wed, 25 Mar 2026 01:48:08 +0200 Subject: [PATCH 3/6] fix: temporary disabled cstore request tracking for dauth_manager.py --- extensions/business/dauth/dauth_manager.py | 4 +++- ver.py | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/extensions/business/dauth/dauth_manager.py b/extensions/business/dauth/dauth_manager.py index 4dc88bbc..42f27ca9 100644 --- a/extensions/business/dauth/dauth_manager.py +++ b/extensions/business/dauth/dauth_manager.py @@ -124,7 +124,9 @@ def on_response(self, method, response): return def process(self): - self._maybe_log_and_save_tracked_requests() + # TODO: this will be re-enabled in the future. + if False: + self._maybe_log_and_save_tracked_requests() return def __get_current_epoch(self): diff --git a/ver.py b/ver.py index 5852fb6b..d9568548 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.132' +__VER__ = '2.10.133' From ed53e895bbcd554d16ffcdf343d96b52ebfd92e2 Mon Sep 17 00:00:00 2001 From: Alessandro Date: Wed, 25 Mar 2026 11:12:50 +0100 Subject: [PATCH 4/6] fix: uppercase project_id filter --- extensions/business/deeploy/deeploy_mixin.py | 2 +- ver.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/extensions/business/deeploy/deeploy_mixin.py b/extensions/business/deeploy/deeploy_mixin.py index 79558ed8..d9d70cae 100644 --- a/extensions/business/deeploy/deeploy_mixin.py +++ b/extensions/business/deeploy/deeploy_mixin.py @@ -2915,7 +2915,7 @@ def _get_apps_by_escrow_active_jobs(self, sender_escrow, owner, project_id=None) ) continue - if project_id is not None and pipeline.get(NetMonCt.DEEPLOY_SPECS, {}).get(DEEPLOY_KEYS.PROJECT_ID) != project_id: + if project_id is not None and pipeline.get(NetMonCt.DEEPLOY_SPECS.upper(), {}).get(DEEPLOY_KEYS.PROJECT_ID) != project_id: self.Pd(f"Skipping R1FS payload for job {job_id}: project_id mismatch.", color='y') continue diff --git a/ver.py b/ver.py index d9568548..499e039f 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.133' +__VER__ = '2.10.134' From f35bc691264828fc08e45b1e522a198bdad01613 Mon Sep 17 00:00:00 2001 From: Cristi Bleotiu Date: Tue, 31 Mar 2026 19:09:14 +0300 Subject: [PATCH 5/6] feat: added new parameter for targeted_topic --- .config_app.json | 3 ++- .config_app_cluster.json | 3 ++- ver.py | 2 +- 3 files changed, 5 insertions(+), 3 deletions(-) diff --git a/.config_app.json b/.config_app.json index 5a02d8e0..7d0c8919 100644 --- a/.config_app.json +++ b/.config_app.json @@ -37,7 +37,8 @@ }, "PASS": "$EE_MQTT", "PAYLOADS_CHANNEL": { - "TOPIC": "naeural/payloads" + "TOPIC": "naeural/payloads", + "TARGETED_TOPIC": "naeural/{}/payloads" }, "PORT": "$EE_MQTT_PORT", "QOS": 2, diff --git a/.config_app_cluster.json b/.config_app_cluster.json index fce3f8d2..0c30f32a 100644 --- a/.config_app_cluster.json +++ b/.config_app_cluster.json @@ -37,7 +37,8 @@ }, "PASS": "$EE_MQTT", "PAYLOADS_CHANNEL": { - "TOPIC": "naeural_test/payloads" + "TOPIC": "naeural_test/payloads", + "TARGETED_TOPIC": "naeural_test/{}/payloads" }, "PORT": "$EE_MQTT_PORT", "QOS": 0, diff --git a/ver.py b/ver.py index 499e039f..bdd2db59 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.134' +__VER__ = '2.10.135' From 0b72a79c68938f641a05a6b9a40e5a837ed96f53 Mon Sep 17 00:00:00 2001 From: Cristi Bleotiu Date: Wed, 1 Apr 2026 16:01:15 +0300 Subject: [PATCH 6/6] chore: prepare for merge --- ver.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ver.py b/ver.py index bdd2db59..1e696423 100644 --- a/ver.py +++ b/ver.py @@ -1 +1 @@ -__VER__ = '2.10.135' +__VER__ = '2.10.140'