flake

Author: maingoh

deepomatic/api/inference.py

@@ -5,7 +5,7 @@
 
 class InferenceResource(object):
     def inference(self, return_task=False, wait_task=True, **kwargs):
-        assert(self._pk is not None)
+        assert (self._pk is not None)
 
         inputs = kwargs.pop('inputs', None)
         if inputs is None:

deepomatic/api/inputs.py

@@ -32,7 +32,7 @@
 ###############################################################################
 
 def format_inputs(inputs, data):
-    assert(isinstance(inputs, list))
+    assert (isinstance(inputs, list))
 
     data = copy.deepcopy(data)
     files = {}

deepomatic/api/mixins.py

@@ -58,7 +58,7 @@ def __init__(self):
 
 class UpdatableResource(object):
     def update(self, replace=False, content_type='application/json', files=None, **kwargs):
-        assert(self._pk is not None)
+        assert (self._pk is not None)
 
         if self._helper.check_query_parameters:
             for arg_name in kwargs:
@@ -78,7 +78,7 @@ def update(self, replace=False, content_type='application/json', files=None, **k
 
 class DeletableResource(object):
     def delete(self):
-        assert(self._pk is not None)
+        assert (self._pk is not None)
         return self._helper.delete(self._uri(pk=self._pk))
 
 

deepomatic/api/resource.py

@@ -47,7 +47,7 @@ def retrieve(self, pk):
         return self.__class__(self._helper, pk=pk)
 
     def refresh(self):
-        assert(self._pk is not None)
+        assert (self._pk is not None)
         self._data = self._helper.get(self._uri(pk=self._pk))
         return self
 

deepomatic/api/resources/recognition.py

@@ -55,7 +55,7 @@ def get_base_uri(cls, pk, public=False, **kwargs):
         return '/recognition/public/' if public else '/recognition/specs/'
 
     def versions(self, offset=0, limit=100):
-        assert(self._pk is not None)
+        assert (self._pk is not None)
         return ResourceList(RecognitionVersion, self._helper, self._uri(pk=self._pk, suffix='versions'), offset, limit)
 
 

deepomatic/api/resources/task.py

@@ -77,7 +77,7 @@ def list(self, task_ids):
         """
         Returns a list of tasks
         """
-        assert(isinstance(task_ids, list))
+        assert (isinstance(task_ids, list))
         return super(Task, self).list(task_ids=task_ids)
 
     def wait(self, **retry_kwargs):

demo.py

@@ -343,11 +343,11 @@ def demo(client=None):
 
     # pending_tasks, error_tasks and success_tasks contains the original offset of the input parameter tasks
     for pos, pending in pending_tasks:
-        assert(tasks[pos].pk == pending.pk)
+        assert (tasks[pos].pk == pending.pk)
     for pos, err in error_tasks:
-        assert(tasks[pos].pk == err.pk)
+        assert (tasks[pos].pk == err.pk)
     for pos, success in success_tasks:
-        assert(tasks[pos].pk == success.pk)
+        assert (tasks[pos].pk == success.pk)
 
 ###########
 # Helpers #

tests/test_client.py

@@ -294,11 +294,11 @@ def test_batch_wait(self, client):
 
         # pending_tasks, error_tasks and success_tasks contains the original offset of the input parameter tasks
         for pos, pending in pending_tasks:
-            assert(tasks[pos].pk == pending.pk)
+            assert (tasks[pos].pk == pending.pk)
         for pos, err in error_tasks:
-            assert(tasks[pos].pk == err.pk)
+            assert (tasks[pos].pk == err.pk)
         for pos, success in success_tasks:
-            assert(tasks[pos].pk == success.pk)
+            assert (tasks[pos].pk == success.pk)
             assert inference_schema(2, 0, 'golden retriever', 0.8) == success['data']
 
         # Task* str(): oneliners (easier to parse in log tooling)