Skip to content

Commit

Permalink
linting fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
bjester committed Jan 11, 2024
1 parent 6b99d6c commit 862f064
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -234,4 +234,4 @@ public CompletableFuture<Result> check(
return null;
}, executor);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -64,4 +64,4 @@ public static StateMap[] forReconciliation() {
RUNNING
};
}
}
}
14 changes: 11 additions & 3 deletions src/taskworker.py
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,11 @@

def main(job_request):
request_id, job_id, process_id, thread_id = job_request.split(',')
logger.info("Starting Kolibri task worker, for job {} and request {}".format(job_id, request_id))
logger.info(
"Starting Kolibri task worker, for job {} and request {}".format(
job_id, request_id
)
)

# Import this after we have initialized Kolibri
from kolibri.core.tasks.worker import execute_job # noqa: E402
Expand All @@ -20,7 +24,11 @@ def main(job_request):
job_id,
worker_process=str(process_id),
worker_thread=str(thread_id),
worker_extra=str(request_id)
worker_extra=str(request_id),
)

logger.info("Ending Kolibri task worker, for job {} and request {}".format(job_id, request_id))
logger.info(
"Ending Kolibri task worker, for job {} and request {}".format(
job_id, request_id
)
)

0 comments on commit 862f064

Please sign in to comment.