@@ -204,6 +204,13 @@ def main():
204
204
205
205
# Check for scheduled scripts
206
206
for script_name , schedule_time in scripts_schedules .items ():
207
+
208
+ # Check if script_name is in already_run or not
209
+ if script_name in already_run and schedule_time != "run" and already_run [script_name ]:
210
+ logger .debug (f"Script: { script_name } has already run setting already_run[{ script_name } ] to False" )
211
+ already_run [script_name ] = False
212
+ elif script_name in already_run and schedule_time == "run" and already_run [script_name ]:
213
+ logger .debug (f"Script is still set to run: { script_name } " )
207
214
208
215
if script_name in running_scripts or not schedule_time :
209
216
continue
@@ -212,6 +219,7 @@ def main():
212
219
if schedule_time == "run" and (script_name not in already_run or not already_run [script_name ]):
213
220
process = run_module (script_name , logger )
214
221
running_scripts [script_name ] = process
222
+ logger .debug (f"Setting already_run[{ script_name } ] to True" )
215
223
already_run [script_name ] = True
216
224
elif schedule_time != "run" and check_schedule (script_name , schedule_time , logger ):
217
225
process = run_module (script_name , logger )
@@ -225,7 +233,6 @@ def main():
225
233
logger .debug (f"already_run:\n { json .dumps (already_run , indent = 4 )} " )
226
234
for script_name in processes_to_remove :
227
235
logger .info (f"Script: { script_name .upper ()} has finished" )
228
- already_run [script_name ] = False
229
236
if script_name in running_scripts :
230
237
del running_scripts [script_name ]
231
238
waiting_message_shown = False
0 commit comments