1 files changed, 174 insertions, 0 deletions
diff --git a/gitlab/v4/objects/pipelines.py b/gitlab/v4/objects/pipelines.py
new file mode 100644
index 0000000..f23df93
--- /dev/null
+++ b/gitlab/v4/objects/pipelines.py
@@ -0,0 +1,174 @@
+from gitlab import cli, types
+from gitlab import exceptions as exc
+from gitlab.base import *  # noqa
+from gitlab.mixins import *  # noqa
+
+
+class ProjectPipeline(RESTObject, RefreshMixin, ObjectDeleteMixin):
+    _managers = (
+        ("jobs", "ProjectPipelineJobManager"),
+        ("bridges", "ProjectPipelineBridgeManager"),
+        ("variables", "ProjectPipelineVariableManager"),
+    )
+
+    @cli.register_custom_action("ProjectPipeline")
+    @exc.on_http_error(exc.GitlabPipelineCancelError)
+    def cancel(self, **kwargs):
+        """Cancel the job.
+
+        Args:
+            **kwargs: Extra options to send to the server (e.g. sudo)
+
+        Raises:
+            GitlabAuthenticationError: If authentication is not correct
+            GitlabPipelineCancelError: If the request failed
+        """
+        path = "%s/%s/cancel" % (self.manager.path, self.get_id())
+        self.manager.gitlab.http_post(path)
+
+    @cli.register_custom_action("ProjectPipeline")
+    @exc.on_http_error(exc.GitlabPipelineRetryError)
+    def retry(self, **kwargs):
+        """Retry the job.
+
+        Args:
+            **kwargs: Extra options to send to the server (e.g. sudo)
+
+        Raises:
+            GitlabAuthenticationError: If authentication is not correct
+            GitlabPipelineRetryError: If the request failed
+        """
+        path = "%s/%s/retry" % (self.manager.path, self.get_id())
+        self.manager.gitlab.http_post(path)
+
+
+class ProjectPipelineManager(RetrieveMixin, CreateMixin, DeleteMixin, RESTManager):
+    _path = "/projects/%(project_id)s/pipelines"
+    _obj_cls = ProjectPipeline
+    _from_parent_attrs = {"project_id": "id"}
+    _list_filters = (
+        "scope",
+        "status",
+        "ref",
+        "sha",
+        "yaml_errors",
+        "name",
+        "username",
+        "order_by",
+        "sort",
+    )
+    _create_attrs = (("ref",), tuple())
+
+    def create(self, data, **kwargs):
+        """Creates a new object.
+
+        Args:
+            data (dict): Parameters to send to the server to create the
+                         resource
+            **kwargs: Extra options to send to the server (e.g. sudo)
+
+        Raises:
+            GitlabAuthenticationError: If authentication is not correct
+            GitlabCreateError: If the server cannot perform the request
+
+        Returns:
+            RESTObject: A new instance of the managed object class build with
+                the data sent by the server
+        """
+        path = self.path[:-1]  # drop the 's'
+        return CreateMixin.create(self, data, path=path, **kwargs)
+
+
+class ProjectPipelineJob(RESTObject):
+    pass
+
+
+class ProjectPipelineJobManager(ListMixin, RESTManager):
+    _path = "/projects/%(project_id)s/pipelines/%(pipeline_id)s/jobs"
+    _obj_cls = ProjectPipelineJob
+    _from_parent_attrs = {"project_id": "project_id", "pipeline_id": "id"}
+    _list_filters = ("scope",)
+
+
+class ProjectPipelineBridge(RESTObject):
+    pass
+
+
+class ProjectPipelineBridgeManager(ListMixin, RESTManager):
+    _path = "/projects/%(project_id)s/pipelines/%(pipeline_id)s/bridges"
+    _obj_cls = ProjectPipelineBridge
+    _from_parent_attrs = {"project_id": "project_id", "pipeline_id": "id"}
+    _list_filters = ("scope",)
+
+
+class ProjectPipelineVariable(RESTObject):
+    _id_attr = "key"
+
+
+class ProjectPipelineVariableManager(ListMixin, RESTManager):
+    _path = "/projects/%(project_id)s/pipelines/%(pipeline_id)s/variables"
+    _obj_cls = ProjectPipelineVariable
+    _from_parent_attrs = {"project_id": "project_id", "pipeline_id": "id"}
+
+
+class ProjectPipelineScheduleVariable(SaveMixin, ObjectDeleteMixin, RESTObject):
+    _id_attr = "key"
+
+
+class ProjectPipelineScheduleVariableManager(
+    CreateMixin, UpdateMixin, DeleteMixin, RESTManager
+):
+    _path = (
+        "/projects/%(project_id)s/pipeline_schedules/"
+        "%(pipeline_schedule_id)s/variables"
+    )
+    _obj_cls = ProjectPipelineScheduleVariable
+    _from_parent_attrs = {"project_id": "project_id", "pipeline_schedule_id": "id"}
+    _create_attrs = (("key", "value"), tuple())
+    _update_attrs = (("key", "value"), tuple())
+
+
+class ProjectPipelineSchedule(SaveMixin, ObjectDeleteMixin, RESTObject):
+    _managers = (("variables", "ProjectPipelineScheduleVariableManager"),)
+
+    @cli.register_custom_action("ProjectPipelineSchedule")
+    @exc.on_http_error(exc.GitlabOwnershipError)
+    def take_ownership(self, **kwargs):
+        """Update the owner of a pipeline schedule.
+
+        Args:
+            **kwargs: Extra options to send to the server (e.g. sudo)
+
+        Raises:
+            GitlabAuthenticationError: If authentication is not correct
+            GitlabOwnershipError: If the request failed
+        """
+        path = "%s/%s/take_ownership" % (self.manager.path, self.get_id())
+        server_data = self.manager.gitlab.http_post(path, **kwargs)
+        self._update_attrs(server_data)
+
+    @cli.register_custom_action("ProjectPipelineSchedule")
+    @exc.on_http_error(exc.GitlabPipelinePlayError)
+    def play(self, **kwargs):
+        """Trigger a new scheduled pipeline, which runs immediately.
+        The next scheduled run of this pipeline is not affected.
+
+        Args:
+            **kwargs: Extra options to send to the server (e.g. sudo)
+
+        Raises:
+            GitlabAuthenticationError: If authentication is not correct
+            GitlabPipelinePlayError: If the request failed
+        """
+        path = "%s/%s/play" % (self.manager.path, self.get_id())
+        server_data = self.manager.gitlab.http_post(path, **kwargs)
+        self._update_attrs(server_data)
+        return server_data
+
+
+class ProjectPipelineScheduleManager(CRUDMixin, RESTManager):
+    _path = "/projects/%(project_id)s/pipeline_schedules"
+    _obj_cls = ProjectPipelineSchedule
+    _from_parent_attrs = {"project_id": "id"}
+    _create_attrs = (("description", "ref", "cron"), ("cron_timezone", "active"))
+    _update_attrs = (tuple(), ("description", "ref", "cron", "cron_timezone", "active"))