Merge pull request #1 from cloudquery/fix/manual-fmt

Author: disq

cloudquery/sdk/internal/memdb/__init__.py

@@ -1,2 +1,2 @@
 
-from .memdb import MemDB
+from .memdb import MemDB

cloudquery/sdk/internal/memdb/memdb.py

@@ -22,4 +22,3 @@ def get_tables(self, options : plugin.TableOptions = None) -> List[plugin.Table]
     def sync(self, options: plugin.SyncOptions) -> Generator[message.SyncMessage, None, None]:
       for table, record in self._memory_db.items():
         yield message.SyncInsertMessage(record)
-      

cloudquery/sdk/scalar/__init__.py

@@ -5,4 +5,4 @@
 from .date32 import Date32
 from .float64 import Float64
 from .int64 import Int64
-from .uuid import UUID
+from .uuid import UUID

cloudquery/sdk/scalar/binary.py

@@ -31,4 +31,4 @@ def set(self, scalar):
           self._valid = True
           self._value = scalar.encode()
       else:
-          raise ScalarInvalidTypeError("Invalid type for Binary scalar")
+          raise ScalarInvalidTypeError("Invalid type for Binary scalar")

cloudquery/sdk/scalar/float64.py

@@ -31,4 +31,4 @@ def set(self, value):
             raise ScalarInvalidTypeError("Invalid type for Float64 scalar")
       else:
           raise ScalarInvalidTypeError("Invalid type for Binary scalar")
-      self._valid = True
+      self._valid = True

cloudquery/sdk/scalar/int64.py

@@ -31,4 +31,4 @@ def set(self, value):
             raise ScalarInvalidTypeError("Invalid type for Int64 scalar") from e
       else:
           raise ScalarInvalidTypeError("Invalid type {} for Int64 scalar".format(type(value)))
-      self._valid = True
+      self._valid = True

cloudquery/sdk/scalar/scalar.py

@@ -12,5 +12,3 @@ def is_valid(self) -> bool:
     @property
     def value(self):
        raise NotImplementedError("Scalar value not implemented")
-
-

cloudquery/sdk/scalar/uuid.py

@@ -30,4 +30,4 @@ def set(self, value):
             raise ScalarInvalidTypeError("Invalid type for UUID scalar") from e
       else:
           raise ScalarInvalidTypeError("Invalid type {} for UUID scalar".format(type(value)))
-      self._valid = True
+      self._valid = True

cloudquery/sdk/scheduler/__init__.py

@@ -1,2 +1,2 @@
 from .scheduler import Scheduler
-from .table_resolver import TableResolver
+from .table_resolver import TableResolver

cloudquery/sdk/scheduler/scheduler.py

@@ -108,17 +108,17 @@ def sync(self, client, resolvers: List[TableResolver], deterministic_cq_id=False
       thread = futures.ThreadPoolExecutor()
       thread.submit(self._sync, client, resolvers, res, deterministic_cq_id)
       total_table_resolvers = 0
-      finished_table_resovlers = 0
+      finished_table_resolvers = 0
       while True:
         message = res.get()
         if type(message) == TableResolverStarted:
           total_table_resolvers += message.count
-          if total_table_resolvers == finished_table_resovlers:
+          if total_table_resolvers == finished_table_resolvers:
             break
           continue
         elif type(message) == TableResolverFinished:
-          finished_table_resovlers += 1
-          if total_table_resolvers == finished_table_resovlers:       
+          finished_table_resolvers += 1
+          if total_table_resolvers == finished_table_resolvers:
             break
           continue
         yield message