main module

class ConnectionBody(*args, **kwargs)

Bases: BaseModel

auth_type: Optional[AuthType] = None

connection_credentials: Optional[dict] = None

connection_name: Optional[constr] = None

connection_type: Optional[str] = None

connector_name: Optional[constr] = None

class CreatePipelineModel(*args, **kwargs)

Bases: BaseModel

batch_size: int = Ellipsis

frequency: str = Ellipsis

hadoop_config: dict = Ellipsis

integration_name: str = Ellipsis

integration_type: str = Ellipsis

schedule_date: list[str] = Ellipsis

schedule_time: str = Ellipsis

source_connection: int = Ellipsis

source_schema: str = Ellipsis

source_table: str = Ellipsis

spark_config: dict = Ellipsis

target_connection: int = Ellipsis

target_schema: str = Ellipsis

target_table: str = Ellipsis

class IntegrationBody(*args, **kwargs)

Bases: BaseModel

batch_size: Optional[int] = None

cron_expression: Optional[List[str]] = None

hadoop_config: Optional[dict] = None

integration_name: Optional[constr] = None

integration_type: Optional[IntegrationType] = None

is_enabled: Optional[bool] = None

is_running: Optional[bool] = None

source_connection: Optional[UUID] = None

source_schema: Optional[constr] = None

source_table: Optional[constr] = None

spark_config: Optional[dict] = None

target_connection: Optional[UUID] = None

target_schema: Optional[constr] = None

target_table: Optional[constr] = None