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