From 5014dfddf9b2a2c657d557871ae1e137b9415726 Mon Sep 17 00:00:00 2001
From: Jakub Jezek <jakub@orbi.tools>
Date: Fri, 1 Apr 2022 16:40:14 +0200
Subject: [PATCH] nuke: adding node knob for concurrent tasks

- and fixing misspelling
---
 openpype/hosts/nuke/api/lib.py                         |  8 ++++++--
 .../deadline/plugins/publish/submit_nuke_deadline.py   | 10 ++++++++--
 .../settings/defaults/project_settings/deadline.json   |  2 +-
 .../projects_schema/schema_project_deadline.json       |  4 ++--
 4 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/openpype/hosts/nuke/api/lib.py b/openpype/hosts/nuke/api/lib.py
index c22488f728..9601244d1d 100644
--- a/openpype/hosts/nuke/api/lib.py
+++ b/openpype/hosts/nuke/api/lib.py
@@ -1048,12 +1048,16 @@ def add_review_knob(node):
 def add_deadline_tab(node):
     node.addKnob(nuke.Tab_Knob("Deadline"))
 
+    knob = nuke.Int_Knob("deadlinePriority", "Priority")
+    knob.setValue(50)
+    node.addKnob(knob)
+
     knob = nuke.Int_Knob("deadlineChunkSize", "Chunk Size")
     knob.setValue(0)
     node.addKnob(knob)
 
-    knob = nuke.Int_Knob("deadlinePriority", "Priority")
-    knob.setValue(50)
+    knob = nuke.Int_Knob("deadlineConcurrentTasks", "Concurrent tasks")
+    knob.setValue(0)
     node.addKnob(knob)
 
 
diff --git a/openpype/modules/deadline/plugins/publish/submit_nuke_deadline.py b/openpype/modules/deadline/plugins/publish/submit_nuke_deadline.py
index 055d3c8a2c..442fcc1ddf 100644
--- a/openpype/modules/deadline/plugins/publish/submit_nuke_deadline.py
+++ b/openpype/modules/deadline/plugins/publish/submit_nuke_deadline.py
@@ -27,7 +27,7 @@ class NukeSubmitDeadline(pyblish.api.InstancePlugin):
     # presets
     priority = 50
     chunk_size = 1
-    concurent_task = 1
+    concurrent_tasks = 1
     primary_pool = ""
     secondary_pool = ""
     group = ""
@@ -154,6 +154,11 @@ class NukeSubmitDeadline(pyblish.api.InstancePlugin):
         if chunk_size == 0 and self.chunk_size:
             chunk_size = self.chunk_size
 
+        # define chunk and priority
+        concurrent_tasks = instance.data.get("deadlineConcurrentTasks")
+        if concurrent_tasks == 0 and self.concurrent_tasks:
+            concurrent_tasks = self.concurrent_tasks
+
         priority = instance.data.get("deadlinePriority")
         if not priority:
             priority = self.priority
@@ -178,7 +183,8 @@ class NukeSubmitDeadline(pyblish.api.InstancePlugin):
 
                 "Priority": priority,
                 "ChunkSize": chunk_size,
-                "ConcurrentTasks": self.concurent_task,
+                "ConcurrentTasks": concurrent_tasks,
+
                 "Department": self.department,
 
                 "Pool": self.primary_pool,
diff --git a/openpype/settings/defaults/project_settings/deadline.json b/openpype/settings/defaults/project_settings/deadline.json
index cfbb92e590..efaaa07be6 100644
--- a/openpype/settings/defaults/project_settings/deadline.json
+++ b/openpype/settings/defaults/project_settings/deadline.json
@@ -62,7 +62,7 @@
             "use_published": true,
             "priority": 50,
             "chunk_size": 10,
-            "concurent_task": 1,
+            "concurrent_tasks": 1,
             "primary_pool": "",
             "secondary_pool": "",
             "group": "",
diff --git a/openpype/settings/entities/schemas/projects_schema/schema_project_deadline.json b/openpype/settings/entities/schemas/projects_schema/schema_project_deadline.json
index 700c3863fb..ea1173313b 100644
--- a/openpype/settings/entities/schemas/projects_schema/schema_project_deadline.json
+++ b/openpype/settings/entities/schemas/projects_schema/schema_project_deadline.json
@@ -207,8 +207,8 @@
                         },
                         {
                             "type": "number",
-                            "key": "concurent_task",
-                            "label": "Number of concurent tasks"
+                            "key": "concurrent_tasks",
+                            "label": "Number of concurrent tasks"
                         },
                         {
                             "type": "splitter"