aboutsummaryrefslogtreecommitdiff
path: root/sheepdog/worker.py
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2022-05-24 05:28:35 +0300
committerFrederick Muriuki Muriithi2022-05-24 05:28:35 +0300
commitbbc4b165761b359115fd1a249ea22e64d55db384 (patch)
tree421c584118ba0f06a57007954aaf71fde84c4000 /sheepdog/worker.py
parent36f8421a8fe223189ab88ee1df3923719ffa4fc0 (diff)
downloadgenenetwork3-bbc4b165761b359115fd1a249ea22e64d55db384.tar.gz
Fix some linting issues
Diffstat (limited to 'sheepdog/worker.py')
-rw-r--r--sheepdog/worker.py9
1 files changed, 5 insertions, 4 deletions
diff --git a/sheepdog/worker.py b/sheepdog/worker.py
index 0209699..6557ab3 100644
--- a/sheepdog/worker.py
+++ b/sheepdog/worker.py
@@ -2,8 +2,9 @@
import os
import sys
import time
-import redis
import argparse
+
+import redis
import redis.connection
# Enable importing from one dir up: put as first to override any other globally
@@ -28,9 +29,7 @@ def make_incremental_backoff(init_val: float=0.1, maximum: int=420):
return current
if command == "increment":
- current = current + abs(value)
- if current > maximum:
- current = maximum
+ current = min(current + abs(value), maximum)
return current
return current
@@ -54,8 +53,10 @@ def run_jobs(conn, queue_name: str = "GN3::job-queue"):
else:
update_status(conn, cmd_id, "error")
return cmd_id
+ return None
def parse_cli_arguments():
+ """Parse the command-line arguments."""
parser = argparse.ArgumentParser(
description="Run asynchronous (service) commands.")
parser.add_argument(