Chore: remove Muster

openpype/lib/connections.py

@@ -6,13 +6,13 @@ def requests_post(*args, **kwargs):
     """Wrap request post method.
 
     Disabling SSL certificate validation if ``DONT_VERIFY_SSL`` environment
-    variable is found. This is useful when Deadline or Muster server are
-    running with self-signed certificates and their certificate is not
+    variable is found. This is useful when Deadline server is
+    running with self-signed certificates and its certificate is not
     added to trusted certificates on client machines.
 
     Warning:
         Disabling SSL certificate validation is defeating one line
-        of defense SSL is providing and it is not recommended.
+        of defense SSL is providing, and it is not recommended.
 
     """
     if "verify" not in kwargs:
@@ -24,13 +24,13 @@ def requests_get(*args, **kwargs):
     """Wrap request get method.
 
     Disabling SSL certificate validation if ``DONT_VERIFY_SSL`` environment
-    variable is found. This is useful when Deadline or Muster server are
-    running with self-signed certificates and their certificate is not
+    variable is found. This is useful when Deadline server is
+    running with self-signed certificates and its certificate is not
     added to trusted certificates on client machines.
 
     Warning:
         Disabling SSL certificate validation is defeating one line
-        of defense SSL is providing and it is not recommended.
+        of defense SSL is providing, and it is not recommended.
 
     """
     if "verify" not in kwargs:

openpype/modules/base.py

@@ -1332,7 +1332,6 @@ class TrayModulesManager(ModulesManager):
         "user",
         "ftrack",
         "kitsu",
-        "muster",
         "launcher_tool",
         "avalon",
         "clockify",

openpype/modules/deadline/abstract_submit_deadline.py

@@ -34,8 +34,8 @@ def requests_post(*args, **kwargs):
     """Wrap request post method.
 
     Disabling SSL certificate validation if ``DONT_VERIFY_SSL`` environment
-    variable is found. This is useful when Deadline or Muster server are
-    running with self-signed certificates and their certificate is not
+    variable is found. This is useful when Deadline server is
+    running with self-signed certificates and its certificate is not
     added to trusted certificates on client machines.
 
     Warning:
@@ -55,8 +55,8 @@ def requests_get(*args, **kwargs):
     """Wrap request get method.
 
     Disabling SSL certificate validation if ``DONT_VERIFY_SSL`` environment
-    variable is found. This is useful when Deadline or Muster server are
-    running with self-signed certificates and their certificate is not
+    variable is found. This is useful when Deadline server is
+    running with self-signed certificates and its certificate is not
     added to trusted certificates on client machines.
 
     Warning:

openpype/modules/deadline/plugins/publish/submit_publish_cache_job.py

@@ -99,10 +99,6 @@ class ProcessSubmittedCacheJobOnFarm(pyblish.api.InstancePlugin,
     def _submit_deadline_post_job(self, instance, job):
         """Submit publish job to Deadline.
 
-        Deadline specific code separated from :meth:`process` for sake of
-        more universal code. Muster post job is sent directly by Muster
-        submitter, so this type of code isn't necessary for it.
-
         Returns:
             (str): deadline_publish_job_id
         """

openpype/modules/deadline/plugins/publish/submit_publish_job.py

@@ -59,21 +59,15 @@ class ProcessSubmittedJobOnFarm(pyblish.api.InstancePlugin,
                                 publish.ColormanagedPyblishPluginMixin):
     """Process Job submitted on farm.
 
-    These jobs are dependent on a deadline or muster job
+    These jobs are dependent on a deadline job
     submission prior to this plug-in.
 
-    - In case of Deadline, it creates dependent job on farm publishing
-      rendered image sequence.
-
-    - In case of Muster, there is no need for such thing as dependent job,
-      post action will be executed and rendered sequence will be published.
+    It creates dependent job on farm publishing rendered image sequence.
 
     Options in instance.data:
         - deadlineSubmissionJob (dict, Required): The returned .json
           data from the job submission to deadline.
 
-        - musterSubmissionJob (dict, Required): same as deadline.
-
         - outputDir (str, Required): The output directory where the metadata
             file should be generated. It's assumed that this will also be
             final folder containing the output files.
@@ -89,7 +83,7 @@ class ProcessSubmittedJobOnFarm(pyblish.api.InstancePlugin,
 
     """
 
-    label = "Submit image sequence jobs to Deadline or Muster"
+    label = "Submit image sequence jobs to Deadline"
     order = pyblish.api.IntegratorOrder + 0.2
     icon = "tractor"
 
@@ -161,10 +155,6 @@ class ProcessSubmittedJobOnFarm(pyblish.api.InstancePlugin,
     def _submit_deadline_post_job(self, instance, job, instances):
         """Submit publish job to Deadline.
 
-        Deadline specific code separated from :meth:`process` for sake of
-        more universal code. Muster post job is sent directly by Muster
-        submitter, so this type of code isn't necessary for it.
-
         Returns:
             (str): deadline_publish_job_id
         """
@@ -581,21 +571,11 @@ def process(self, instance):
         ._____.
 
         '''
-
-        render_job = None
-        submission_type = ""
-        if instance.data.get("toBeRenderedOn") == "deadline":
-            render_job = instance.data.pop("deadlineSubmissionJob", None)
-            submission_type = "deadline"
-
-        if instance.data.get("toBeRenderedOn") == "muster":
-            render_job = instance.data.pop("musterSubmissionJob", None)
-            submission_type = "muster"
+        render_job = instance.data.pop("deadlineSubmissionJob", None)
 
         if not render_job and instance.data.get("tileRendering") is False:
-            raise AssertionError(("Cannot continue without valid Deadline "
-                                  "or Muster submission."))
-
+            raise AssertionError(("Cannot continue without valid "
+                                  "Deadline submission."))
         if not render_job:
             import getpass
 
@@ -624,21 +604,19 @@ def process(self, instance):
                 "FTRACK_SERVER": os.environ.get("FTRACK_SERVER"),
             }
 
-        deadline_publish_job_id = None
-        if submission_type == "deadline":
-            # get default deadline webservice url from deadline module
-            self.deadline_url = instance.context.data["defaultDeadline"]
-            # if custom one is set in instance, use that
-            if instance.data.get("deadlineUrl"):
-                self.deadline_url = instance.data.get("deadlineUrl")
-            assert self.deadline_url, "Requires Deadline Webservice URL"
+        # get default deadline webservice url from deadline module
+        self.deadline_url = instance.context.data["defaultDeadline"]
+        # if custom one is set in instance, use that
+        if instance.data.get("deadlineUrl"):
+            self.deadline_url = instance.data.get("deadlineUrl")
+        assert self.deadline_url, "Requires Deadline Webservice URL"
 
-            deadline_publish_job_id = \
-                self._submit_deadline_post_job(instance, render_job, instances)
+        deadline_publish_job_id = \
+            self._submit_deadline_post_job(instance, render_job, instances)
 
-            # Inject deadline url to instances.
-            for inst in instances:
-                inst["deadlineUrl"] = self.deadline_url
+        # Inject deadline url to instances.
+        for inst in instances:
+            inst["deadlineUrl"] = self.deadline_url
 
         # publish job file
         publish_job = {
@@ -664,15 +642,6 @@ def process(self, instance):
         if audio_file and os.path.isfile(audio_file):
             publish_job.update({"audio": audio_file})
 
-        # pass Ftrack credentials in case of Muster
-        if submission_type == "muster":
-            ftrack = {
-                "FTRACK_API_USER": os.environ.get("FTRACK_API_USER"),
-                "FTRACK_API_KEY": os.environ.get("FTRACK_API_KEY"),
-                "FTRACK_SERVER": os.environ.get("FTRACK_SERVER"),
-            }
-            publish_job.update({"ftrack": ftrack})
-
         metadata_path, rootless_metadata_path = \
             create_metadata_path(instance, anatomy)