Merge branch 'main' into support/3.2

zatosource · May 13, 2024 · ddfd107 · ddfd107
2 parents 8cf359d + 423a9d4
commit ddfd107
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/code/zato-server/src/zato/server/file_transfer/observer/base.py b/code/zato-server/src/zato/server/file_transfer/observer/base.py
@@ -72,11 +72,17 @@ def __init__(self, manager:'FileTransferAPI', channel_config:'Bunch') -> 'None':
  self.is_notify = self.observer_type_impl == FILE_TRANSFER.SOURCE_TYPE_IMPL.LOCAL_INOTIFY
  self.name = channel_config.name
  self.is_active = channel_config.is_active
- self.sleep_time = default_interval
  self.path_list = ['<initial-observer>']
  self.is_recursive = False
  self.keep_running = True
 
+ if pickup_interval := (os.environ.get('Zato_Hot_Deploy_Interval') or os.environ.get('Zato_Hot_Deployment_Interval')):
+ pickup_interval = int(pickup_interval)
+ else:
+ pickup_interval = default_interval
+
+ self.sleep_time = pickup_interval
+
 # ################################################################################################################################
 
  def set_up(self, event_handler:'any_', path_list:'anylist', recursive:'bool') -> 'None':