From 0d235ed8cacffb9196a54e1b3cf40fbcc36fd57e Mon Sep 17 00:00:00 2001
From: Petr Kalis <petr.kalis@gmail.com>
Date: Wed, 22 Oct 2025 18:58:20 +0200
Subject: [PATCH] Create destination task if no task selected

---
 .../tools/push_to_project/models/integrate.py | 29 +++++++++++++++++--
 1 file changed, 27 insertions(+), 2 deletions(-)

diff --git a/client/ayon_core/tools/push_to_project/models/integrate.py b/client/ayon_core/tools/push_to_project/models/integrate.py
index ef49838152..a7cb1de95a 100644
--- a/client/ayon_core/tools/push_to_project/models/integrate.py
+++ b/client/ayon_core/tools/push_to_project/models/integrate.py
@@ -762,8 +762,11 @@ class ProjectPushItemProcess:
             )
         self._folder_entity = folder_entity
         if not dst_task_name:
-            self._task_info = {}
-            return
+            dst_task_name = self._make_sure_task_exists(folder_entity)
+
+            if not dst_task_name:  # really no task selected nor on source
+                self._task_info = {}
+                return
 
         folder_path = folder_entity["path"]
         folder_tasks = {
@@ -962,6 +965,28 @@ class ProjectPushItemProcess:
         )
         self._version_entity = version_entity
 
+    def _make_sure_task_exists(self, folder_entity: Dict[str, Any]) -> str:
+        """Creates destination task from source task information"""
+        project_name = self._item.dst_project_name
+        src_version_entity = self._src_version_entity
+        src_task = ayon_api.get_task_by_id(
+            self._item.src_project_name, src_version_entity["taskId"]
+        )
+        if not src_task:
+            self._status.set_failed(
+                f"No task selected and couldn't find source task"
+            )
+            raise PushToProjectError(self._status.fail_reason)
+        _task_id = ayon_api.create_task(
+            project_name,
+            src_task["name"],
+            folder_id=folder_entity["id"],
+            task_type=src_task["taskType"],
+            attrib=src_task["attrib"],
+        )
+
+        return src_task["name"]
+
     def _integrate_representations(self):
         try:
             self._real_integrate_representations()