fix append for merge in iceberg

dlt-hub · Oct 5, 2023 · bd9744c · bd9744c
1 parent 202466f
commit bd9744c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dlt/destinations/athena/athena.py b/dlt/destinations/athena/athena.py
@@ -372,10 +372,10 @@ def create_table_chain_completed_followup_jobs(self, table_chain: Sequence[TTabl
         """Creates a list of followup jobs for merge write disposition and staging replace strategies"""
         jobs = super().create_table_chain_completed_followup_jobs(table_chain)
 
-        # no jobs if we are merging: TODO: add proper iceberg merge job
+        # append job if there is a merge TODO: add proper iceberg merge job
         write_disposition = table_chain[0]["write_disposition"]
         if write_disposition == "merge":
-            return []
+            jobs.append(self._create_staging_copy_job(table_chain, False))
 
         # add some additional jobs
         write_disposition = table_chain[0]["write_disposition"]