fix: patch ruff format

Author: DanielBlei

workloads/ingest/ingest/core/config.py

@@ -10,20 +10,20 @@
 
 class DatabaseType(str, Enum):
     """Database type enumeration."""
-    
+
     MYSQL = "mysql"
     POSTGRES = "postgres"
 
 
 class TargetType(str, Enum):
     """Target type enumeration."""
-    
+
     BIGQUERY = "bigquery"
 
 
 class SourceConfig(BaseModel):
     """Source database configuration."""
-    
+
     name: str
     type: DatabaseType
     host: str
@@ -51,7 +51,7 @@ def build_connection_string(self, dialect: str, default_port: int = 0) -> str:
 
 class BigQueryTargetConfig(BaseModel):
     """BigQuery target configuration."""
-    
+
     name: str
     type: TargetType = TargetType.BIGQUERY
     project_id: str = Field(
@@ -77,23 +77,23 @@ class BigQueryTargetConfig(BaseModel):
 
 class RuntimeParams(BaseModel):
     """Runtime parameters for ingestion process."""
-    
+
     retry_attempts: int = Field(ge=1, le=10, default=3)
     retry_delay_seconds: int = Field(ge=1, le=3600, default=30)
     chunk_size: int = Field(default=10000)
 
 
 class SecretProvider(str, Enum):
     """Secret provider enumeration."""
-    
+
     GOOGLE_SECRET_MANAGER = "gcloud"
     # AWS_SECRET_MANAGER = "aws"
     # AZURE_KEY_VAULT = "azure"
 
 
 class SecretConfig(BaseModel):
     """Secret configuration."""
-    
+
     provider: SecretProvider = Field(
         default=SecretProvider.GOOGLE_SECRET_MANAGER, description="Secret Manager Provider"
     )
@@ -107,7 +107,7 @@ class SecretConfig(BaseModel):
 
 class Config(BaseModel):
     """Main configuration class."""
-    
+
     version: str
     params: RuntimeParams
     secrets: List[SecretConfig]

workloads/ingest/ingest/sources/source.py

@@ -20,12 +20,15 @@ class SourceInterface(Protocol):
     def connect(self) -> None:
         """Connect to the data source."""
         ...
+
     def extract(self, table: Table, chunk_size: int, limit: Optional[int] = None) -> Iterator[dict]:
         """Extract data from the source."""
         ...
+
     def validate_connection(self) -> bool:
         """Validate the connection to the source."""
         ...
+
     def close(self) -> None:
         """Close the connection to the source."""
         ...

workloads/ingest/ingest/targets/target.py

@@ -18,6 +18,7 @@ class TargetInterface(Protocol):
     def load(self, data: list[dict], target_table: str) -> None:
         """Load data into the target."""
         ...
+
     def validate_connection(self) -> bool:
         """Validate the connection to the target."""
         ...