Renamed the job_info contextvar into current_job

4 files changed, 10 insertions, 10 deletions

diff --git a/src/apscheduler/__init__.py b/src/apscheduler/__init__.py
index be2f038..6b5828d 100644
--- a/src/apscheduler/__init__.py
+++ b/src/apscheduler/__init__.py
@@ -43,12 +43,12 @@ __all__ = [
     "WorkerStopped",
     "current_scheduler",
     "current_worker",
-    "job_info",
+    "current_job",
 ]
 
 from typing import Any
 
-from ._context import current_scheduler, current_worker, job_info
+from ._context import current_job, current_scheduler, current_worker
 from ._enums import CoalescePolicy, ConflictPolicy, JobOutcome, RunState
 from ._events import (
     DataStoreEvent,
diff --git a/src/apscheduler/_context.py b/src/apscheduler/_context.py
index 42ccf87..cc5aff2 100644
--- a/src/apscheduler/_context.py
+++ b/src/apscheduler/_context.py
@@ -4,9 +4,9 @@ from contextvars import ContextVar
 from typing import TYPE_CHECKING
 
 if TYPE_CHECKING:
+    from ._structures import JobInfo
     from .schedulers.async_ import AsyncScheduler
     from .schedulers.sync import Scheduler
-    from .structures import JobInfo
     from .workers.async_ import AsyncWorker
     from .workers.sync import Worker
 
@@ -19,4 +19,4 @@ current_worker: ContextVar[Worker | AsyncWorker | None] = ContextVar(
     "current_worker", default=None
 )
 #: Metadata about the current job
-job_info: ContextVar[JobInfo] = ContextVar("job_info")
+current_job: ContextVar[JobInfo] = ContextVar("job_info")
diff --git a/src/apscheduler/workers/async_.py b/src/apscheduler/workers/async_.py
index 4c965ae..a44c89c 100644
--- a/src/apscheduler/workers/async_.py
+++ b/src/apscheduler/workers/async_.py
@@ -20,7 +20,7 @@ from anyio import (
 )
 from anyio.abc import CancelScope, TaskGroup
 
-from .._context import current_worker, job_info
+from .._context import current_job, current_worker
 from .._converters import as_async_datastore, as_async_eventbroker
 from .._enums import JobOutcome, RunState
 from .._events import JobAdded, WorkerStarted, WorkerStopped
@@ -178,7 +178,7 @@ class AsyncWorker:
                 await self.data_store.release_job(self.identity, job.task_id, result)
                 return
 
-            token = job_info.set(JobInfo.from_job(job))
+            token = current_job.set(JobInfo.from_job(job))
             try:
                 retval = func(*job.args, **job.kwargs)
                 if isawaitable(retval):
@@ -202,6 +202,6 @@ class AsyncWorker:
                 )
                 await self.data_store.release_job(self.identity, job.task_id, result)
             finally:
-                job_info.reset(token)
+                current_job.reset(token)
         finally:
             self._running_jobs.remove(job.id)
diff --git a/src/apscheduler/workers/sync.py b/src/apscheduler/workers/sync.py
index 16265e8..1d8f85a 100644
--- a/src/apscheduler/workers/sync.py
+++ b/src/apscheduler/workers/sync.py
@@ -15,7 +15,7 @@ from uuid import UUID
 
 import attrs
 
-from .._context import current_worker, job_info
+from .._context import current_job, current_worker
 from .._enums import JobOutcome, RunState
 from .._events import JobAdded, WorkerStarted, WorkerStopped
 from .._structures import Job, JobInfo, JobResult
@@ -206,7 +206,7 @@ class Worker:
                 self.data_store.release_job(self.identity, job.task_id, result)
                 return
 
-            token = job_info.set(JobInfo.from_job(job))
+            token = current_job.set(JobInfo.from_job(job))
             try:
                 retval = func(*job.args, **job.kwargs)
             except BaseException as exc:
@@ -222,6 +222,6 @@ class Worker:
                 )
                 self.data_store.release_job(self.identity, job.task_id, result)
             finally:
-                job_info.reset(token)
+                current_job.reset(token)
         finally:
             self._running_jobs.remove(job.id)