Fix type error

dlt-hub · Feb 23, 2024 · 0882987 · 0882987
1 parent b7acf93
commit 0882987
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/dlt/extract/resource.py b/dlt/extract/resource.py
@@ -352,7 +352,10 @@ def parallelize(self) -> "DltResource":
         """
         if (
             not inspect.isgenerator(self._pipe.gen)
-            and not inspect.isgeneratorfunction(inspect.unwrap(self._pipe.gen))
+            and not (
+                callable(self._pipe.gen)
+                and inspect.isgeneratorfunction(inspect.unwrap(self._pipe.gen))
+            )
             and not (callable(self._pipe.gen) and self.is_transformer)
         ):
             raise InvalidParallelResourceDataType(self.name, self._pipe.gen, type(self._pipe.gen))