Merge pull request #92 from Tilix4/feature-sync_paired_proj_startup

Feature: Sync paired projects at processor startup

Author: martastain

services/processor/processor/fullsync.py

@@ -46,9 +46,16 @@ def get_tasks(
     return tasks
 
 
-def full_sync(
+def project_full_sync(
     parent: "KitsuProcessor", kitsu_project_id: str, project_name: str
 ):
+    """Sync all entities from a Kitsu project to an Ayon project.
+
+    Args:
+        parent (KitsuProcessor): The parent processor
+        kitsu_project_id (str): The Kitsu project id
+        project_name (str): The Ayon
+    """
     start_time = time.time()
     logging.info(f"Syncing kitsu project {kitsu_project_id} to {project_name}")
 

services/processor/processor/processor.py

@@ -8,7 +8,7 @@
 import gazu
 from nxtools import log_traceback, logging
 
-from .fullsync import full_sync
+from .fullsync import project_full_sync
 from .update_from_kitsu import (
     create_or_update_asset,
     create_or_update_concept,
@@ -308,8 +308,18 @@ def set_paired_ayon_project(
 
     def start_processing(self):
         logging.info("KitsuProcessor started")
+        startup = True
 
         while True:
+            # Sync all paired projects
+            if startup:
+                logging.info("Running sync for all paired projects")
+                for pair in self.pairing_list:
+                    if pair.get("kitsuProjectId") and pair.get("ayonProjectName"):
+                        project_full_sync(self, pair["kitsuProjectId"], pair["ayonProjectName"])
+                startup = False
+
+            # Check for a new sync job
             job = ayon_api.enroll_event_job(
                 source_topic="kitsu.sync_request",
                 target_topic="kitsu.sync",
@@ -336,7 +346,7 @@ def start_processing(self):
             )
 
             try:
-                full_sync(self, kitsu_project_id, ayon_project_name)
+                project_full_sync(self, kitsu_project_id, ayon_project_name)
 
                 # if successful add the pair to the list
                 self.set_paired_ayon_project(