diff --git a/pulsar/managers/staging/pre.py b/pulsar/managers/staging/pre.py index 8e844e6f..5411237e 100644 --- a/pulsar/managers/staging/pre.py +++ b/pulsar/managers/staging/pre.py @@ -17,8 +17,6 @@ def preprocess(job_directory, setup_actions, action_executor, was_cancelled, obj action = from_dict(setup_action["action"]) if getattr(action, "inject_object_store", False): action.object_store = object_store - if getattr(action, "inject_job_directory", False): - action.job_directory = job_directory path = job_directory.calculate_path(name, input_type) description = "Staging {} '{}' via {} to {}".format(input_type, name, action, path) log.debug(description) diff --git a/pulsar/scripts/submit_util.py b/pulsar/scripts/submit_util.py index 071069fe..c00a2c32 100644 --- a/pulsar/scripts/submit_util.py +++ b/pulsar/scripts/submit_util.py @@ -5,7 +5,6 @@ import time from pulsar.client.util import from_base64_json -from pulsar.client.manager import build_client_manager from pulsar.main import ( load_pulsar_app, PulsarManagerConfigBuilder, @@ -21,7 +20,6 @@ def add_common_submit_args(arg_parser): arg_parser.add_argument("--file", default=None) arg_parser.add_argument("--base64", default=None) - arg_parser.add_argument("--build_client_manager", default=None) PulsarManagerConfigBuilder.populate_options(arg_parser) @@ -34,10 +32,6 @@ def run_server_for_job(args): submit_job(manager, job_config) if wait: log.info("Co-execution job setup, now waiting for job completion and postprocessing.") - if args.build_client_manager: - client_manager = build_client_manager(arc_enabled=True) - client = client_manager.get_client({"arc_url": "http://localhost:8082", "jobs_directory": "/works"}, job_id=job_config["job_id"]) - client.launch() wait_for_job(manager, job_config) log.info("Leaving finish_execution and shutting down app") except BaseException: