|
21 | 21 | from opentelemetry import trace |
22 | 22 | from opentelemetry.trace.propagation.tracecontext import TraceContextTextMapPropagator |
23 | 23 |
|
24 | | -from api.services.arguments_storage import ArgumentsStorage |
25 | 24 | from api.models import ComputeResource, Job, JobConfig, DEFAULT_PROGRAM_ENTRYPOINT |
26 | 25 | from api.services.file_storage import FileStorage, WorkingDir |
27 | 26 | from api.utils import ( |
@@ -113,27 +112,6 @@ def submit(self, job: Job) -> Optional[str]: |
113 | 112 | f"Program [{program.title}] has no image or artifact associated." |
114 | 113 | ) |
115 | 114 |
|
116 | | - # upload arguments to working directory |
117 | | - provider_name = None |
118 | | - if job.program.provider is not None: |
119 | | - provider_name = job.program.provider.name |
120 | | - storage = ArgumentsStorage( |
121 | | - job.author.username, program.title, provider_name |
122 | | - ) |
123 | | - arguments = storage.get(job.id) |
124 | | - arguments_file = os.path.join( |
125 | | - working_directory_for_upload, "arguments.serverless" |
126 | | - ) |
127 | | - |
128 | | - # DEPRECATED: arguments is now saved in /:username/:jobid, |
129 | | - # arguments.serverless is going to be deprecated |
130 | | - with open(arguments_file, "w", encoding="utf-8") as f: |
131 | | - if arguments: |
132 | | - logger.debug("uploading arguments for job [%s]", job.id) |
133 | | - f.write(arguments) |
134 | | - else: |
135 | | - f.write("{}") |
136 | | - |
137 | 115 | # set tracing |
138 | 116 | carrier: dict[str, str] = {} |
139 | 117 | TraceContextTextMapPropagator().inject(carrier) |
|
0 commit comments