diff --git a/flow/connectors/clickhouse/qrep_avro_sync.go b/flow/connectors/clickhouse/qrep_avro_sync.go index 9c10965f49..bc815626df 100644 --- a/flow/connectors/clickhouse/qrep_avro_sync.go +++ b/flow/connectors/clickhouse/qrep_avro_sync.go @@ -125,8 +125,7 @@ func (s *ClickhouseAvroSyncMethod) SyncQRepRecords( creds, err := s.connector.credsProvider.Provider.Retrieve(ctx) if err != nil { - // TODO what to return here? - return -1, err + return 0, err } avroFileUrl := fmt.Sprintf("https://%s.s3.%s.amazonaws.com/%s", s3o.Bucket,