Write a Python function run_incremental_load(source_conn, target_conn, watermark_table) that: reads the last watermark from a state table, queries the source for rows updated_at > watermark, upserts them into the target table, then updates the watermark. Handle failures safely.
Sign in to see what a strong answer covers and to get AI feedback on your own.