global: add tasks endpoint

invenio_jobs/ext.py

@@ -10,8 +10,13 @@
 from invenio_i18n import gettext as _
 
 from . import config
-from .resources import JobsResource, JobsResourceConfig
-from .services import JobsService, JobsServiceConfig
+from .resources import (
+    JobsResource,
+    JobsResourceConfig,
+    TasksResource,
+    TasksResourceConfig,
+)
+from .services import JobsService, JobsServiceConfig, TasksService, TasksServiceConfig
 
 
 class InvenioJobs:
@@ -38,10 +43,14 @@ def init_config(self, app):
     def init_services(self, app):
         """Initialize services."""
         self.service = JobsService(JobsServiceConfig.build(app))
+        self.tasks_service = TasksService(TasksServiceConfig.build(app))
 
     def init_resource(self, app):
         """Initialize resources."""
         self.jobs_resource = JobsResource(JobsResourceConfig.build(app), self.service)
+        self.tasks_resource = TasksResource(
+            TasksResourceConfig.build(app), self.tasks_service
+        )
 
 
 def finalize_app(app):
@@ -51,3 +60,4 @@ def finalize_app(app):
 
     # services
     rr_ext.registry.register(ext.service, service_id="jobs")
+    rr_ext.registry.register(ext.tasks_service, service_id="tasks")

invenio_jobs/resources/__init__.py

@@ -7,10 +7,12 @@
 
 """Jobs resources."""
 
-from .config import JobsResourceConfig
-from .resources import JobsResource
+from .config import JobsResourceConfig, TasksResourceConfig
+from .resources import JobsResource, TasksResource
 
 __all__ = (
     "JobsResource",
     "JobsResourceConfig",
+    "TasksResource",
+    "TasksResourceConfig",
 )

invenio_jobs/services/__init__.py

@@ -7,12 +7,14 @@
 
 """Services."""
 
-from .config import JobsServiceConfig
+from .config import JobsServiceConfig, TasksServiceConfig
 from .schema import JobSchema
-from .services import JobsService
+from .services import JobsService, TasksService
 
 __all__ = (
     "JobSchema",
     "JobsService",
     "JobsServiceConfig",
+    "TasksService",
+    "TasksServiceConfig",
 )

invenio_jobs/services/config.py

@@ -18,10 +18,24 @@
 
 from ..models import Job, Run
 from .links import JobLink
-from .permissions import JobPermissionPolicy
+from .permissions import JobPermissionPolicy, TasksPermissionPolicy
 from .schema import JobSchema
 
 
+class TasksServiceConfig(ServiceConfig, ConfiguratorMixin):
+    """TaskService factory configuration."""
+
+    # Common configuration
+    service_id = "tasks"
+    permission_policy_cls = TasksPermissionPolicy
+
+    result_list_cls = RecordList
+
+    links_item = {
+        "self": JobLink("{+api}/tasks"),
+    }
+
+
 class JobSearchOptions(SearchOptionsBase):
     """Job search options."""
 

invenio_jobs/services/permissions.py

@@ -11,6 +11,16 @@
 from invenio_records_permissions.policies import BasePermissionPolicy
 
 
+class TasksPermissionPolicy(BasePermissionPolicy):
+    """Access control configuration for tasks."""
+
+    can_search = [Administration()]
+    can_create = [Administration()]
+    can_read = [Administration()]
+    can_update = [Administration()]
+    can_delete = [Administration()]
+
+
 class JobPermissionPolicy(BasePermissionPolicy):
     """Access control configuration for jobs."""
 

invenio_jobs/services/services.py

@@ -11,6 +11,14 @@
 from invenio_records_resources.services.uow import unit_of_work
 
 
+class TasksService(RecordService):
+    """Tasks service."""
+
+    def search(self, identity, **kwargs):
+        """Search for jobs."""
+        raise NotImplementedError()
+
+
 class JobsService(RecordService):
     """Jobs service."""
 

invenio_jobs/views.py

@@ -20,3 +20,9 @@ def create_jobs_bp(app):
     """Create jobs blueprint."""
     ext = app.extensions["invenio-jobs"]
     return ext.jobs_resource.as_blueprint()
+
+
+def create_tasks_bp(app):
+    """Create tasks blueprint."""
+    ext = app.extensions["invenio-jobs"]
+    return ext.tasks_resource.as_blueprint()

setup.cfg

@@ -64,6 +64,7 @@ invenio_base.api_apps =
     jobs = invenio_jobs:InvenioJobs
 invenio_base.api_blueprints =
     jobs = invenio_jobs.views:create_jobs_bp
+    tasks = invenio_jobs.views:create_tasks_bp
 invenio_base.finalize_app =
     jobs = invenio_jobs.ext:finalize_app
 invenio_base.api_finalize_app =