pass arguments by file instead of by envvar

Signed-off-by: Paul S. Schweigert <[email protected]>

client/qiskit_serverless/serializers/program_serializers.py

@@ -81,4 +81,8 @@ def get_arguments() -> Dict[str, Any]:
     Returns:
         Dictionary of arguments.
     """
-    return json.loads(os.environ.get(ENV_JOB_ARGUMENTS, "{}"), cls=QiskitObjectsDecoder)
+    arguments = "{}"
+    if os.path.isfile("arguments.serverless"):
+        with open("arguments.serverless", "r") as f:
+            arguments = f.read()
+    return json.loads(arguments, cls=QiskitObjectsDecoder)

gateway/api/ray.py

@@ -118,6 +118,12 @@ def submit(self, job: Job) -> Optional[str]:
             # get entrypoint
             entrypoint = f"python {program.entrypoint}"
 
+            # upload arguments to working directory
+            if job.arguments:
+                logger.debug("uploading arguments for job %s", job.id)
+                with open(working_directory_for_upload + "/arguments.serverless", "w") as f:
+                    f.write(job.arguments)
+
             # set tracing
             carrier = {}
             TraceContextTextMapPropagator().inject(carrier)

gateway/api/utils.py

@@ -135,7 +135,6 @@ def build_env_variables(token, job: Job, arguments: str) -> Dict[str, str]:
             "ENV_JOB_GATEWAY_TOKEN": str(token),
             "ENV_JOB_GATEWAY_HOST": str(settings.SITE_HOST),
             "ENV_JOB_ID_GATEWAY": str(job.id),
-            "ENV_JOB_ARGUMENTS": arguments,
         },
         **extra,
     }