add schedule to script

Author: Hagellach37

mapswipe_workers/python_scripts/update_project_status.py

@@ -1,3 +1,8 @@
+import sys
+import time
+
+import schedule as sched
+
 from mapswipe_workers.auth import firebaseDB
 from mapswipe_workers.definitions import MessageType, logger
 from mapswipe_workers.utils.slack_helper import send_slack_message
@@ -45,20 +50,22 @@ def set_status_in_firebase(project_id, project_name, new_status):
         send_slack_message(MessageType.PROJECT_STATUS_ACTIVE, project_name, project_id)
 
 
-if __name__ == "__main__":
-    """Check if project status should be updated and change value in Firebase."""
-    filter_string = "Test"
-
+def run_update_project_status(filter_string):
+    """Run the workflow to update project status for all filtered projects."""
+    logger.info("### Start update project status workflow ###")
     active_projects = get_projects(status="active")
     finished_projects = filter_projects_by_name_and_progress(
-        active_projects, filter_string, progress_threshold=1,
+        active_projects, filter_string, progress_threshold=100,
     )
 
     inactive_projects = get_projects(status="inactive")
     new_active_projects = filter_projects_by_name_and_progress(
         inactive_projects, filter_string, progress_threshold=0,
     )[0 : len(finished_projects)]
 
+    # Here we check that there is at least one inactive project
+    # which can be activated in the app.
+    # We do this to avoid that there is no project left in the app.
     if len(new_active_projects) > 0:
         for project_id in finished_projects:
             project_name = active_projects[project_id]["name"]
@@ -67,3 +74,22 @@ def set_status_in_firebase(project_id, project_name, new_status):
         for project_id in new_active_projects:
             project_name = inactive_projects[project_id]["name"]
             set_status_in_firebase(project_id, project_name, new_status="active")
+    logger.info("### Finished update project status workflow ###")
+
+
+if __name__ == "__main__":
+    """Check if project status should be updated and change value in Firebase."""
+    try:
+        filter_string = sys.argv[1]
+        time_interval = int(sys.argv[2])
+    except IndexError:
+        logger.info("Please provide the filter_string and time_interval arguments.")
+        sys.exit(1)
+
+    sched.every(time_interval).minutes.do(
+        run_update_project_status, filter_string=filter_string
+    ).run()
+
+    while True:
+        sched.run_pending()
+        time.sleep(1)