moved client into azure preprocessing

main.py

@@ -25,12 +25,31 @@ SIMSHIP_WEBHOOK_SECRET = os.environ.get("SIMSHIP_WEBHOOK_SECRET")
 AZURE_SUBSCRIPTION_ID = os.getenv('AZURE_SUBSCRIPTION_ID')
 AZURE_RESOURCE_GROUP = os.getenv('AZURE_RESOURCE_GROUP')
 
-client = MLClient(
-    credential=DefaultAzureCredential(),
-    subscription_id=AZURE_SUBSCRIPTION_ID,
-    resource_group_name=AZURE_RESOURCE_GROUP,
-    registry_name="HuggingFace",
-)
+def archive_model_in_azure(model_id: str) -> None:
+    client = MLClient(
+        credential=DefaultAzureCredential(),
+        subscription_id=AZURE_SUBSCRIPTION_ID,
+        resource_group_name=AZURE_RESOURCE_GROUP,
+        registry_name="HuggingFace",
+    )
+
+    name = model_id.replace("/", "-").replace("_", "-").lower()
+    models = list(client.models.list(name=name))
+    if len(models) < 1:
+        msg = f"Model {name} not available in Azure ML, then no need to delete anything."
+        logger.error(msg)
+        raise ValueError(msg)
+
+    for model in models:
+        try:
+            client.models.archive(name=model.name, version=model.version)  # type: ignore
+            logger.info(f"Archived {model.name=} {model.version=}")
+        except Exception as e:
+            msg = f"Failed when archiving model with {name=} with exception {e}"
+            logger.error(msg)
+            raise RuntimeError(msg)
+
+    logger.info(f"Model {name} already archived on Azure ML!")
 
 def send_slack_message(payload: dict, max_retries: int = 3, timeout: int = 10, retry_delay: int = 2):
     """
@@ -186,25 +205,6 @@ def process_simship_webhook(data: dict):
     else:
         pass
 
-def archive_model_in_azure(model_id: str) -> None:
-    name = model_id.replace("/", "-").replace("_", "-").lower()
-    models = list(client.models.list(name=name))
-    if len(models) < 1:
-        msg = f"Model {name} not available in Azure ML, then no need to delete anything."
-        logger.error(msg)
-        raise ValueError(msg)
-
-    for model in models:
-        try:
-            client.models.archive(name=model.name, version=model.version)  # type: ignore
-            logger.info(f"Archived {model.name=} {model.version=}")
-        except Exception as e:
-            msg = f"Failed when archiving model with {name=} with exception {e}"
-            logger.error(msg)
-            raise RuntimeError(msg)
-
-    logger.info(f"Model {name} already archived on Azure ML!")
-
 app = FastAPI()
 
 @app.post("/webhook/model-catalog")