[COST-4573] Sync partitions prior to querying data for bill creation (#…

…4868)
project-koku · Jan 16, 2024 · 961f2c4 · 961f2c4
1 parent ecee6d6
commit 961f2c4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/koku/masu/processor/parquet/parquet_report_processor.py b/koku/masu/processor/parquet/parquet_report_processor.py
@@ -492,11 +492,11 @@ def create_parquet_table(self, parquet_file, daily=False, partition_map=None):
             processor.create_schema()
         if not processor.table_exists():
             processor.create_table(partition_map=partition_map)
-        if not daily:
-            processor.create_bill(bill_date=bill_date)
+        self.trino_table_exists[self.report_type] = True
         processor.get_or_create_postgres_partition(bill_date=bill_date)
         processor.sync_hive_partitions()
-        self.trino_table_exists[self.report_type] = True
+        if not daily:
+            processor.create_bill(bill_date=bill_date)
 
     def check_required_columns_for_ingress_reports(self, col_names):
         LOG.info(log_json(msg="checking required columns for ingress reports", context=self._context))