missing parameter

AbsaOSS · Aug 26, 2024 · 5401307 · 5401307
1 parent a0d5a02
commit 5401307
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rialto/runner/runner.py b/rialto/runner/runner.py
@@ -121,7 +121,7 @@ def check_dates_have_partition(self, table: Table, dates: List[date]) -> List[bo
         :param dates: list of dates to check
         :return: list of bool
         """
-        if utils.table_exists(table.get_table_path()):
+        if utils.table_exists(self.spark, table.get_table_path()):
             partitions = utils.get_partitions(self.reader, table)
             return [(date in partitions) for date in dates]
         else: