@@ -43,7 +43,7 @@ def create_namespace(self, namespace_name, owner_name, description=None):
4343 if description :
4444 payload ['description' ] = description
4545
46- return self ._backend .put (
46+ self ._backend .put (
4747 self ._path ('/namespaces/{0}' , namespace_name ),
4848 headers = _HEADERS ,
4949 payload = payload
@@ -64,7 +64,7 @@ def create_source(self, source_name, source_type, connection_url,
6464 if description :
6565 payload ['description' ] = description
6666
67- return self ._backend .put (
67+ self ._backend .put (
6868 self ._path ('/sources/{0}' , source_name ),
6969 headers = _HEADERS ,
7070 payload = payload )
@@ -105,7 +105,7 @@ def create_dataset(self, namespace_name, dataset_name, dataset_type,
105105 if schema_location :
106106 payload ['schemaLocation' ] = schema_location
107107
108- return self ._backend .put (
108+ self ._backend .put (
109109 self ._path ('/namespaces/{0}/datasets/{1}' , namespace_name ,
110110 dataset_name ),
111111 headers = _HEADERS ,
@@ -139,7 +139,7 @@ def create_job(self, namespace_name, job_name, job_type,
139139 if description :
140140 payload ['description' ] = description
141141
142- return self ._backend .put (
142+ self ._backend .put (
143143 self ._path ('/namespaces/{0}/jobs/{1}' , namespace_name , job_name ),
144144 headers = _HEADERS ,
145145 payload = payload
@@ -175,24 +175,24 @@ def create_job_run(self, namespace_name, job_name, run_id,
175175 response = self .mark_job_run_as_started (
176176 run_id , str (datetime .datetime .utcnow ()))
177177
178- return response
178+ response
179179
180180 def mark_job_run_as_started (self , run_id , action_at = None ):
181- return self .__mark_job_run_as (run_id , 'start' , action_at )
181+ self .__mark_job_run_as (run_id , 'start' , action_at )
182182
183183 def mark_job_run_as_completed (self , run_id , action_at = None ):
184- return self .__mark_job_run_as (run_id , 'complete' , action_at )
184+ self .__mark_job_run_as (run_id , 'complete' , action_at )
185185
186186 def mark_job_run_as_failed (self , run_id , action_at = None ):
187- return self .__mark_job_run_as (run_id , 'fail' , action_at )
187+ self .__mark_job_run_as (run_id , 'fail' , action_at )
188188
189189 def mark_job_run_as_aborted (self , run_id , action_at = None ):
190- return self .__mark_job_run_as (run_id , 'abort' , action_at )
190+ self .__mark_job_run_as (run_id , 'abort' , action_at )
191191
192192 def __mark_job_run_as (self , run_id , action , action_at = None ):
193193 Utils .is_valid_uuid (run_id , 'run_id' )
194194
195- return self ._backend .post (
195+ self ._backend .post (
196196 self ._path ('/jobs/runs/{0}/{1}?at={2}' , run_id , action ,
197197 action_at if action_at else Utils .utc_now ()),
198198 headers = _HEADERS ,
0 commit comments