quick fix for tests

Author: nickzoic

countess/core/pipeline.py

@@ -98,7 +98,7 @@ def run(self, ddbc, row_limit: Optional[int] = None) -> None:
         # get detected on the next sweep
         self.status = PipelineNodeStatus.WORKING
 
-        if self.table_name:
+        if ddbc and self.table_name:
             ddbc.sql(f"DROP TABLE IF EXISTS {self.table_name}")
 
         try: