Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ SCHEDULER_CONFIG = SchedulerConfiguration(
SCHEDULER_INTERVAL=10,
BROKER=Broker.REDIS,
CALLBACK_TIMEOUT=60, # Callback timeout in seconds (success/failure/stopped)
# Default values, can be overriden per task/job
# Default values, can be overridden per task/job
DEFAULT_SUCCESS_TTL=10 * 60, # Time To Live (TTL) in seconds to keep successful job results
DEFAULT_FAILURE_TTL=365 * 24 * 60 * 60, # Time To Live (TTL) in seconds to keep job failure information
DEFAULT_JOB_TTL=10 * 60, # Time To Live (TTL) in seconds to keep job information
Expand Down
2 changes: 1 addition & 1 deletion docs/configuration.md
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ SCHEDULER_CONFIG = SchedulerConfiguration(
SCHEDULER_INTERVAL=10,
BROKER=Broker.REDIS,
CALLBACK_TIMEOUT=60, # Callback timeout in seconds (success/failure/stopped)
# Default values, can be overriden per task/job
# Default values, can be overridden per task/job
DEFAULT_SUCCESS_TTL=10 * 60, # Time To Live (TTL) in seconds to keep successful job results
DEFAULT_FAILURE_TTL=365 * 24 * 60 * 60, # Time To Live (TTL) in seconds to keep job failure information
DEFAULT_JOB_TTL=10 * 60, # Time To Live (TTL) in seconds to keep job information
Expand Down
2 changes: 1 addition & 1 deletion docs/installation.md
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@
SCHEDULER_INTERVAL=10,
BROKER=Broker.REDIS,
CALLBACK_TIMEOUT=60, # Callback timeout in seconds (success/failure/stopped)
# Default values, can be overriden per task/job
# Default values, can be overridden per task/job
DEFAULT_SUCCESS_TTL=10 * 60, # Time To Live (TTL) in seconds to keep successful job results
DEFAULT_FAILURE_TTL=365 * 24 * 60 * 60, # Time To Live (TTL) in seconds to keep job failure information
DEFAULT_JOB_TTL=10 * 60, # Time To Live (TTL) in seconds to keep job information
Expand Down
2 changes: 1 addition & 1 deletion scheduler/decorators.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ def __init__(
:param result_ttl: Result time to live
:param job_info_ttl: Time to live for job info
:param at_front: Whether to enqueue the job at front of the queue
:param meta: Arbitraty metadata about the job
:param meta: Arbitrary metadata about the job
:param description: Job description
:param on_failure: Callable to run on failure
:param on_success: Callable to run on success
Expand Down
2 changes: 1 addition & 1 deletion scheduler/helpers/timeouts.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ def __exit__(self, type, value, traceback):
# situation and consider the body done.
pass

# __exit__ may return True to supress further exception handling. We don't want to suppress any exceptions
# __exit__ may return True to suppress further exception handling. We don't want to suppress any exceptions
# here, since all errors should just pass through, BaseTimeoutException being handled normally to the invoking
# context.
return False
Expand Down
2 changes: 1 addition & 1 deletion scheduler/templates/admin/scheduler/job_detail.html
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ <h2>Job {{ job.name }}
</div>
</fieldset>
<fieldset class="module aligned">
<h2 class="fieldset-heading">Job queue interation</h2>
<h2 class="fieldset-heading">Job queue interaction</h2>
<div class="field-row">
<div class="flex-container form-multiline">
<div class="fieldBox">
Expand Down
4 changes: 2 additions & 2 deletions scheduler/worker/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -284,7 +284,7 @@ def bootstrap(self) -> None:
"""Bootstraps the worker.
Runs the basic tasks that should run when the worker actually starts working.
Used so that new workers can focus on the work loop implementation rather
than the full bootstraping process.
than the full bootstrapping process.
"""
self.worker_start()
self.log(INFO, f"Worker {self.name} started with PID {os.getpid()}")
Expand Down Expand Up @@ -563,7 +563,7 @@ def fork_job_execution_process(self, job: JobModel, queue: Queue) -> None:
self._set_procline(f"Forked {child_pid} at {time.time()}")

def get_heartbeat_ttl(self, job: JobModel) -> int:
"""Get's the TTL for the next heartbeat.
"""Gets the TTL for the next heartbeat.
:param job: The Job
:return: The heartbeat TTL
"""
Expand Down
Loading