Skip to content

Made competition container and temp folder names more readable #2194

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
Didayolo merged 2 commits into from
Feb 17, 2026
Merged

Made competition container and temp folder names more readable #2194

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
b398440
changed uuid naming scheme for ingestion and scoring containers to us…
Feb 16, 2026
9ab95e8
Rename variable following snake_case convention
Didayolo Feb 17, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 19 additions & 7 deletions compute_worker/compute_worker.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -323,10 +323,13 @@ class Run:
"""

def __init__(self, run_args):
self.run_related_name = (
f"uPK-{run_args['user_pk']}_sID-{run_args['id']}"
)
# Directories for the run
self.watch = True
self.completed_program_counter = 0
self.root_dir = tempfile.mkdtemp(dir=BASE_DIR)
self.root_dir = tempfile.mkdtemp(prefix=f'{self.run_related_name}__', dir=BASE_DIR)
self.bundle_dir = os.path.join(self.root_dir, "bundles")
self.input_dir = os.path.join(self.root_dir, "input")
self.output_dir = os.path.join(self.root_dir, "output")
Expand All @@ -349,8 +352,8 @@ def __init__(self, run_args):
self.stdout, self.stderr, self.ingestion_stdout, self.ingestion_stderr = (
self._get_stdout_stderr_file_names(run_args)
)
self.ingestion_container_name = uuid.uuid4()
self.program_container_name = uuid.uuid4()
self.ingestion_container_name = f"ingestion_{self.run_related_name}"
self.program_container_name = f"scoring_{self.run_related_name}"
self.program_data = run_args.get("program_data")
self.ingestion_program_data = run_args.get("ingestion_program")
self.input_data = run_args.get("input_data")
Expand Down Expand Up @@ -449,10 +452,14 @@ async def send_detailed_results(self, file_path):
)
)
except Exception as e:
logger.error(f"This error might result in a Execution Time Exceeded error: {e}")
logger.error(
f"This error might result in a Execution Time Exceeded error: {e}"
)
if os.environ.get("LOG_LEVEL", "info").lower() == "debug":
logger.exception(e)
raise SubmissionException("Could not connect to instance to update detailed result")
raise SubmissionException(
"Could not connect to instance to update detailed result"
)

def _get_stdout_stderr_file_names(self, run_args):
# run_args should be the run_args argument passed to __init__ from the run_wrapper.
Expand Down Expand Up @@ -1223,11 +1230,16 @@ def start(self):
# Check if scoring program failed
program_results, _, _ = task_results
# Gather returns either normal values or exception instances when return_exceptions=True
had_async_exc = isinstance(program_results, BaseException) and not isinstance(program_results, asyncio.CancelledError)
had_async_exc = isinstance(
program_results, BaseException
) and not isinstance(program_results, asyncio.CancelledError)
program_rc = getattr(self, "program_exit_code", None)
failed_rc = program_rc not in (0, None)
if had_async_exc or failed_rc:
self._update_status(STATUS_FAILED, extra_information=f"program_rc={program_rc}, async={task_results}")
self._update_status(
STATUS_FAILED,
extra_information=f"program_rc={program_rc}, async={task_results}",
)
# Raise so upstream marks failed immediately
raise SubmissionException("Child task failed or non-zero return code")
self._update_status(STATUS_FINISHED)
Expand Down