From 23afac3d7742426a0532125e483b28aa45d402e9 Mon Sep 17 00:00:00 2001 From: mvdbeek Date: Tue, 12 Nov 2024 15:52:06 +0100 Subject: [PATCH] Outline next steps --- pulsar/client/client.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/pulsar/client/client.py b/pulsar/client/client.py index 8478742d..d6d20166 100644 --- a/pulsar/client/client.py +++ b/pulsar/client/client.py @@ -492,9 +492,12 @@ def launch( pulsar_app_config=None, staging_manifest=None ) -> Optional[ExternalId]: + # 1. call staging script with staging manifest [handled by ARC] + # 2. call actual command_line + # 3. call script that does output collection (similar to __collect_outputs) and outputs staging manifest + # 4. stage outputs back using manifest [handled by ARC] pass - class CoexecutionLaunchMixin(BaseRemoteConfiguredJobClient): execution_type: ExecutionType pulsar_container_image: str