Add error handling to custom destination lanceDB example

Signed-off-by: Marcel Coetzee <[email protected]>
dlt-hub · May 13, 2024 · c165619 · c165619
1 parent 0ca8c7a
commit c165619
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py b/docs/examples/custom_destination_lancedb/custom_destination_lancedb.py
@@ -142,6 +142,7 @@ def lancedb_destination(items: TDataItems, table: TTableSchema) -> None:
     load_info = pipeline.run(
         spotify_shows(client_id=dlt.secrets.value, client_secret=dlt.secrets.value),
     )
+    load_info.raise_on_failed_jobs()
 
     row_counts = pipeline.last_trace.last_normalize_info