Your daily Airflow job failed halfway through. How do you design the pipeline so that restarting it doesn't create duplicate records for Aircall?