Migrate run end-point and use function.run instead of client.run

.github/workflows/docker-build.yaml

@@ -69,4 +69,3 @@ jobs:
         if: ${{ failure() }}
         run: |
           docker compose logs gateway
-          docker compose logs jupyter

.github/workflows/notebook-local-verify.yaml

@@ -1,4 +1,4 @@
-name: Notebook LocalProvider tests
+name: Notebook LocalClient tests
 
 on:
   pull_request:
@@ -16,8 +16,8 @@ jobs:
       - name: patch notebooks
         shell: bash
         run: |
-          for f in tests/basic/*.py; do sed -i "s/import ServerlessProvider/import LocalProvider/;s/= ServerlessProvider(/= LocalProvider(/;/token=os\.environ\.get/d;/host=os\.environ\.get/d" "$f"; done
-          for f in tests/experimental/*.py; do sed -i "s/import ServerlessProvider/import LocalProvider/;s/= ServerlessProvider(/= LocalProvider(/;/token=os\.environ\.get/d;/host=os\.environ\.get/d" "$f"; done
+          for f in tests/basic/*.py; do sed -i "s/import ServerlessClient/import LocalClient/;s/= ServerlessClient(/= LocalClient(/;/token=os\.environ\.get/d;/host=os\.environ\.get/d" "$f"; done
+          for f in tests/experimental/*.py; do sed -i "s/import ServerlessClient/import LocalClient/;s/= ServerlessClient(/= LocalClient(/;/token=os\.environ\.get/d;/host=os\.environ\.get/d" "$f"; done
       - name: install dependencies
         shell: bash
         run: pip install client/

client/qiskit_serverless/__init__.py

@@ -25,7 +25,7 @@
     BaseProvider,
     BaseClient,
     distribute_task,
-    distribute_qiskit_pattern,
+    distribute_qiskit_function,
     get,
     put,
     get_refs_by_status,

client/qiskit_serverless/core/__init__.py

@@ -44,7 +44,7 @@
     fetch_execution_meta
     distribute_task
     distribute_program
-    distribute_qiskit_pattern
+    distribute_qiskit_function
     get
     put
     get_refs_by_status
@@ -82,7 +82,7 @@
     get_refs_by_status,
     fetch_execution_meta,
     distribute_task,
-    distribute_qiskit_pattern,
+    distribute_qiskit_function,
     distribute_program,
     Target,
     CircuitMeta,

client/qiskit_serverless/core/client.py

@@ -448,10 +448,16 @@ def run(
     ) -> Job:
         tracer = trace.get_tracer("client.tracer")
         with tracer.start_as_current_span("Provider.run"):
+            warnings.warn(
+                "`run` method has been deprecated. "
+                "And will be removed in future releases. "
+                "Please, use `function.run` instead.",
+                DeprecationWarning,
+            )
             if isinstance(program, QiskitFunction) and program.entrypoint is not None:
-                job = self._job_client.run(program, arguments, config)
+                job = self._job_client.run(program.title, arguments, config)
             else:
-                job = self._job_client.run_existing(program, arguments, config)
+                job = self._job_client.run(program, arguments, config)
         return job
 
     def upload(self, program: QiskitFunction):
@@ -661,10 +667,16 @@ def run(
         arguments: Optional[Dict[str, Any]] = None,
         config: Optional[Configuration] = None,
     ) -> Job:
+        warnings.warn(
+            "`client.run` method has been deprecated. "
+            "And will be removed in future releases. "
+            "Please, use `function.run` instead.",
+            DeprecationWarning,
+        )
         if isinstance(program, QiskitFunction) and program.entrypoint is not None:
-            job = self.client.run(program, arguments)
+            job = self.client.run(program.title, arguments, config)
         else:
-            job = self.client.run_existing(program, arguments)
+            job = self.client.run(program, arguments, config)
         return job
 
     def get_job_by_id(self, job_id: str) -> Optional[Job]:
@@ -712,6 +724,9 @@ def file_delete(self, file: str):
             return None
         raise NotImplementedError("files method is not implemented in LocalProvider.")
 
+    def list(self, **kwargs):
+        return self.client.get_programs(**kwargs)
+
 
 class LocalProvider(LocalClient):
     """

client/qiskit_serverless/core/decorators.py

@@ -333,15 +333,15 @@ def wrapper(*args, **kwargs):
 """
 
 
-def distribute_qiskit_pattern(
+def distribute_qiskit_function(
     provider: Optional[Any] = None,
     dependencies: Optional[List[str]] = None,
     working_dir: Optional[str] = None,
 ):
-    """[Experimental] QiskitPattern decorator to turn function into remotely executable program.
+    """[Experimental] QiskitFunction decorator to turn function into remotely executable program.
 
     Example:
-        >>> @distribute_qiskit_pattern(provider=ServerlessProvider(...), dependencies=[...])
+        >>> @distribute_qiskit_function(provider=ServerlessProvider(...), dependencies=[...])
         >>> def my_program():
         >>>     print("Hola!")
         >>>
@@ -357,7 +357,7 @@ def distribute_qiskit_pattern(
     """
     # pylint: disable=import-outside-toplevel,cyclic-import
     from qiskit_serverless import QiskitServerlessException
-    from qiskit_serverless.core.function import QiskitPattern
+    from qiskit_serverless.core.function import QiskitFunction
     from qiskit_serverless.core.client import ServerlessProvider
 
     # create provider
@@ -412,14 +412,16 @@ def wrapper(*args, **kwargs):
                 file.write(ENTRYPOINT_CONTENT.format(file_name=pickle_file_name))
 
             # create program
-            wrapped_program = QiskitPattern(
+            wrapped_program = QiskitFunction(
                 title=function.__name__,
                 entrypoint=entrypoint_file_name,
                 working_dir=working_directory,
                 dependencies=dependencies,
-                description="QiskitPattern execution using @distribute_program decorator.",
+                description="QiskitFunction execution using @distribute_program decorator.",
             )
 
+            provider.upload(wrapped_program)
+
             # run program
             job = provider.run(wrapped_program, arguments=kwargs)
 
@@ -446,6 +448,6 @@ def distribute_program(
     warnings.warn(
         "`distribute_program` has been deprecated "
         "and will be removed in future releases. "
-        "Please, use `distribute_qiskit_pattern` instead."
+        "Please, use `distribute_qiskit_function` instead."
     )
-    return distribute_qiskit_pattern(provider, dependencies, working_dir)
+    return distribute_qiskit_function(provider, dependencies, working_dir)

client/qiskit_serverless/core/function.py

@@ -85,21 +85,19 @@ def run(self, **kwargs):
             raise ValueError("No clients specified for a function.")
 
         if self.validate:
-            is_valid, validation_errors = self._validate_funciton()
+            is_valid, validation_errors = self._validate_function()
             if not is_valid:
                 error_string = "\n".join(validation_errors)
                 raise ValueError(
                     f"Function validation failed. Validation errors:\n {error_string}",
                 )
 
-        if self._is_local_function():
-            return self.job_client.run(program=self, arguments=kwargs)
-        return self.job_client.run_existing(program=self.title, arguments=kwargs)
+        config = kwargs.pop("config", None)
+        return self.job_client.run_existing(
+            program=self.title, arguments=kwargs, config=config
+        )
 
-    def _is_local_function(self) -> bool:
-        return self.entrypoint is not None and self.working_dir is not None
-
-    def _validate_funciton(self) -> Tuple[bool, List[str]]:
+    def _validate_function(self) -> Tuple[bool, List[str]]:
         """Validate function arguments using schema provided.
 
         Returns: