Multithreading in linking multiple issues (#66)

* Changed the linking of multiple issue functianlity with usage of multithreading to speed up the results

* Formatted code

* Change log modified to minor version instead of patch version

* Changed pack version

* Added inward and outward keys in output for better debug

* Code formatting

Author: karamveer28

CHANGES.md

@@ -1,5 +1,9 @@
 # Change Log
 
+## 2.5.0
+
+- Added multithreading in linking multiple issue functionality to speed up the response.
+
 ## 2.4.2
 
 - Update `formatters.py` to include `priority` field

actions/bulk_link_issue.py

@@ -1,21 +1,50 @@
+import threading
+from threading import Semaphore
 from lib.base import BaseJiraAction
 
-__all__ = [
-    'BulkLinkJiraIssueAction'
-]
-
 
 class BulkLinkJiraIssueAction(BaseJiraAction):
+    def link_issues(
+        self,
+        semaphore,
+        issue_key=None,
+        target_issue=None,
+        direction=None,
+        link_type=None,
+    ):
+        with semaphore:
+            outward_issue_key = ""
+            inward_issue_key = ""
+            if direction == "outward":
+                outward_issue_key = issue_key
+                inward_issue_key = target_issue
+                response = self._client.create_issue_link(
+                    link_type, inward_issue_key, outward_issue_key
+                )
+
+            if direction == "inward":
+                inward_issue_key = issue_key
+                outward_issue_key = target_issue
+                response = self._client.create_issue_link(
+                    link_type, inward_issue_key, outward_issue_key
+                )
+            response_output = {
+                "inward_issue": inward_issue_key,
+                "outward_issue": outward_issue_key,
+                "response": response,
+            }
+        print(response_output)
+
+    def run(self, issue_key_list, target_issue, direction, link_type):
+        threads = list()
+        semaphore = Semaphore(10)
+        for issue_key in issue_key_list:
+            x = threading.Thread(
+                target=self.link_issues,
+                args=(semaphore, issue_key, target_issue, direction, link_type),
+            )
+            threads.append(x)
+            x.start()
 
-    def run(self, issue_key_list=None, target_issue=None, direction=None, link_type=None):
-        if direction == 'outward':
-            inward_issue_key = target_issue
-            for outward_issue_key in issue_key_list:
-                issue = self._client.create_issue_link(link_type, inward_issue_key,
-                                                       outward_issue_key)
-        if direction == 'inward':
-            outward_issue_key = target_issue
-            for inward_issue_key in issue_key_list:
-                issue = self._client.create_issue_link(link_type, inward_issue_key,
-                                                       outward_issue_key)
-        return issue
+        for thread in threads:
+            thread.join()

actions/bulk_link_issue.yaml

@@ -25,4 +25,4 @@ parameters:
     type: string
     description: The type of link to create.
     required: true
-    default: relates
+    default: relates to

actions/link_issue.yaml

@@ -17,3 +17,4 @@ parameters:
     type: string
     description: The type of link to create.
     required: true
+    default: relates to

pack.yaml

@@ -6,7 +6,7 @@ keywords:
   - issues
   - ticket management
   - project management
-version: 2.4.2
+version: 2.5.0
 python_versions:
   - "3"
 author : StackStorm, Inc.