include subscription_name in partial finished notification

Author: unknown

src/galaxy/api/plugin.py

@@ -129,7 +129,7 @@ async def _import_element(self, id_, context_):
             logger.exception("Unexpected exception raised in %s importer", self._name)
             self._notification_failure(id_, UnknownError())
         finally:
-            self._notification_partial_finished()
+            self._notification_partial_finished(id_)
 
 
 class Plugin:
@@ -722,8 +722,13 @@ def _subscription_games_import_failure(self, subscription_name: str, error: Appl
             }
         )
 
-    def _subscriptions_games_partial_import_finished(self) -> None:
-        self._connection.send_notification("subscription_games_partial_import_finished", None)
+    def _subscriptions_games_partial_import_finished(self, subscription_name: str) -> None:
+        self._connection.send_notification(
+            "subscription_games_partial_import_finished",
+            {
+               "subscription_name": subscription_name
+            }
+        )
 
     def _subscription_games_import_finished(self) -> None:
         self._connection.send_notification("subscription_games_import_finished", None)

tests/test_subscriptions.py

@@ -143,7 +143,10 @@ async def sub_games():
         {
             'jsonrpc': '2.0',
             'method':
-            'subscription_games_partial_import_finished', 'params': None
+                'subscription_games_partial_import_finished',
+                'params': {
+                    "subscription_name": "sub_a"
+                }
         },
         {
             "jsonrpc": "2.0",
@@ -191,7 +194,10 @@ async def sub_games():
         {
             'jsonrpc': '2.0',
             'method':
-                'subscription_games_partial_import_finished', 'params': None
+                'subscription_games_partial_import_finished',
+                'params': {
+                    "subscription_name": "sub_a"
+                }
         },
         {
             "jsonrpc": "2.0",
@@ -242,7 +248,10 @@ async def test_get_subscription_games_error(exception, code, message, plugin, re
         {
             'jsonrpc': '2.0',
             'method':
-                'subscription_games_partial_import_finished', 'params': None
+                'subscription_games_partial_import_finished',
+                'params': {
+                    "subscription_name": "sub_a"
+                }
         },
         {
             "jsonrpc": "2.0",