From c5eaf57463cf84fa7ded2e4e6b139247de76acf2 Mon Sep 17 00:00:00 2001
From: Sumesh Surendran Kannathuparambil
 <35956666+Sumeshks29@users.noreply.github.com>
Date: Mon, 30 Sep 2019 18:55:35 +0530
Subject: [PATCH] added jobs endpoint (#10)

---
 tvarit_api/resources/__init__.py |  1 +
 tvarit_api/resources/job.py      | 27 +++++++++++++++++++++++++++
 tvarit_api/tvarit.py             |  2 ++
 3 files changed, 30 insertions(+)
 create mode 100644 tvarit_api/resources/job.py

diff --git a/tvarit_api/resources/__init__.py b/tvarit_api/resources/__init__.py
index e0a21c1..426c656 100644
--- a/tvarit_api/resources/__init__.py
+++ b/tvarit_api/resources/__init__.py
@@ -18,3 +18,4 @@
 from .handler import Handler
 from .task import Task
 from .output import Output
+from .job import Job
diff --git a/tvarit_api/resources/job.py b/tvarit_api/resources/job.py
new file mode 100644
index 0000000..88dae01
--- /dev/null
+++ b/tvarit_api/resources/job.py
@@ -0,0 +1,27 @@
+from .base import Base
+
+
+class Job(Base):
+    def __init__(self, api):
+        super(Job, self).__init__(api)
+        self.api = api
+
+    def run_job(self, job):
+        endpoint = "/jobs"
+        return self.api.POST(endpoint, json=job)
+
+    def rerun_job(self, job_id):
+        endpoint = "/{}/rerun".format(job_id)
+        return self.api.POST(endpoint)
+
+    def abort_job(self, job_id):
+        endpoint = "/{}/abort".format(job_id)
+        return self.api.POST(endpoint)
+
+    def job_status(self, job_id):
+        endpoint = "/{}/status".format(job_id)
+        return self.api.POST(endpoint)
+
+    def job_logs(self, job_id):
+        endpoint = "/{}/logs".format(job_id)
+        return self.api.POST(endpoint)
diff --git a/tvarit_api/tvarit.py b/tvarit_api/tvarit.py
index 51c9f6c..afe683d 100644
--- a/tvarit_api/tvarit.py
+++ b/tvarit_api/tvarit.py
@@ -20,6 +20,7 @@
     Handler,
     Task,
     Output,
+    Job
 )
 
 
@@ -62,3 +63,4 @@ def __init__(
         self.handler = Handler(self.api)
         self.task = Task(self.api)
         self.output = Output(self.api)
+        self.job = Job(self.api)