
                    timestamper.insert(row).await.map_err(|e| SourceError {
                        source_name: source_name.clone(),
                        error: SourceErrorDetails::FileIO(e.to_string()),
                    })?;
                }
            }

            info!(