Develop

.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,

.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,

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):

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
 

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):

ver.py

@@ -1 +1 @@
-__VER__ = '2.10.130'
+__VER__ = '2.10.140'