--wip-- [skip ci]

Author: tdstein

src/posit/connect/content.py

@@ -19,6 +19,8 @@
     overload,
 )
 
+from posit.connect.jobs import _Jobs, Job
+
 from . import tasks
 from ._api import ApiDictEndpoint, JsonifiableDict
 from .bundles import Bundles
@@ -514,7 +516,7 @@ def tags(self) -> ContentItemTags:
     @property
     def jobs(self) -> Jobs:
         path = posixpath.join(self._path, "jobs")
-        return _ResourceSequence(self._ctx, path, uid="key")
+        return _Jobs(self._ctx, path, uid="key")
 
     @property
     @requires(version="2024.11.0")

src/posit/connect/jobs.py

@@ -1,13 +1,15 @@
 from __future__ import annotations
 
+from typing import Any, List
+
 from typing_extensions import (
     Iterable,
     Literal,
     Protocol,
     runtime_checkable,
 )
 
-from .resources import Resource, ResourceSequence
+from .resources import Resource, ResourceSequence, _Resource, _ResourceSequence
 
 JobTag = Literal[
     "unknown",
@@ -39,6 +41,7 @@
 StatusCode = Literal[0, 1, 2]
 
 
+@runtime_checkable
 class Job(Resource, Protocol):
     def destroy(self) -> None:
         """Destroy the job.
@@ -53,6 +56,11 @@ def destroy(self) -> None:
         """
 
 
+class _Job(_Resource):
+    def wait_for(self) -> None:
+        pass
+
+
 @runtime_checkable
 class Jobs(ResourceSequence[Job], Protocol):
     def fetch(self) -> Iterable[Job]:
@@ -165,3 +173,9 @@ def find_by(
         This action requires administrator, owner, or collaborator privileges.
         """
         ...
+
+
+class _Jobs(_ResourceSequence[Job]):
+    def fetch(self, **conditions) -> Iterable[Any]:
+        resources = super().fetch(**conditions)
+        return [_Job(**resource) for resource in resources]