Skip to content

Commit

Permalink
[chore]: apply pre-commit hooks
Browse files Browse the repository at this point in the history
  • Loading branch information
GLEF1X committed Jan 20, 2023
1 parent cffcaa9 commit d579fd0
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 8 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/deploy.yml
Original file line number Diff line number Diff line change
Expand Up @@ -57,4 +57,4 @@ jobs:
uses: pypa/gh-action-pypi-publish@master
with:
user: __token__
password: ${{ secrets.PYPI_TOKEN }}
password: ${{ secrets.PYPI_TOKEN }}
2 changes: 1 addition & 1 deletion apscheduler_di/_binding.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
from inspect import Signature, _ParameterKind
from typing import Any, Callable, Dict, List, TypeVar, get_type_hints

from rodi import CannotResolveTypeException, ActivationScope, Services
from rodi import ActivationScope, CannotResolveTypeException, Services

T = TypeVar('T', bound=Callable[..., Any])

Expand Down
12 changes: 6 additions & 6 deletions apscheduler_di/_inject.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,23 +13,23 @@
from apscheduler_di._serialization import SharedJob


def inject_dependencies_to_scheduler(scheduler: BaseScheduler, container: Container) -> None:
def inject_dependencies_to_scheduler(
scheduler: BaseScheduler, container: Container
) -> None:
services = container.build_provider()
for job_store in scheduler._jobstores.values(): # type: BaseJobStore # noqa

def func_get_due_jobs_with_context(c: BaseJobStore, now: datetime) -> List[Job]:
jobs: List[Job] = type(c).get_due_jobs(c, now)
return _convert_raw_to_easy_maintainable_jobs(
scheduler, jobs, services
)
return _convert_raw_to_easy_maintainable_jobs(scheduler, jobs, services)

job_store.get_due_jobs = types.MethodType(
func_get_due_jobs_with_context, job_store
)


def _convert_raw_to_easy_maintainable_jobs(
scheduler: BaseScheduler, jobs: List[Job], services: Services
scheduler: BaseScheduler, jobs: List[Job], services: Services
) -> List[Job]:
unsafe_pickling = False
if isinstance(scheduler, BlockingScheduler):
Expand All @@ -43,7 +43,7 @@ def _convert_raw_to_easy_maintainable_jobs(


def _make_jobs_shared(
jobs: List[Job], scheduler: BaseScheduler, services: Services
jobs: List[Job], scheduler: BaseScheduler, services: Services
) -> List[SharedJob]:
shared_jobs: List[SharedJob] = []
for job in jobs:
Expand Down

0 comments on commit d579fd0

Please sign in to comment.