diff --git a/README.md b/README.md index f0ef295..7c9401b 100644 --- a/README.md +++ b/README.md @@ -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 diff --git a/docs/configuration.md b/docs/configuration.md index 00ae6e3..f06bd1f 100644 --- a/docs/configuration.md +++ b/docs/configuration.md @@ -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 diff --git a/docs/installation.md b/docs/installation.md index e1edcab..b71b561 100644 --- a/docs/installation.md +++ b/docs/installation.md @@ -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 diff --git a/scheduler/decorators.py b/scheduler/decorators.py index 08472c1..d9d1339 100644 --- a/scheduler/decorators.py +++ b/scheduler/decorators.py @@ -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 diff --git a/scheduler/helpers/timeouts.py b/scheduler/helpers/timeouts.py index 15d4bf3..0f539da 100644 --- a/scheduler/helpers/timeouts.py +++ b/scheduler/helpers/timeouts.py @@ -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 diff --git a/scheduler/templates/admin/scheduler/job_detail.html b/scheduler/templates/admin/scheduler/job_detail.html index 5263c73..14faefa 100644 --- a/scheduler/templates/admin/scheduler/job_detail.html +++ b/scheduler/templates/admin/scheduler/job_detail.html @@ -83,7 +83,7 @@

Job {{ job.name }}
-

Job queue interation

+

Job queue interaction

diff --git a/scheduler/worker/worker.py b/scheduler/worker/worker.py index 9d2468f..48c1d3e 100644 --- a/scheduler/worker/worker.py +++ b/scheduler/worker/worker.py @@ -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()}") @@ -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 """