async def get_by_integration_type(
        self, db: AsyncSession, integration_type: IntegrationType, organization_id: UUID
    ) -> list[Connection]:
        """Get all active connections for a specific integration type, including native connections.

        This combines organization-specific connections with the system-level native connections.
        Native connections are included if they match the integration type.

        Args:
            db: The database session
            integration_type: The integration type to filter by
            organization_id: The organization ID

        Returns:
            A list of Connection objects including both organization connections and native ones
        """
        # Query for org-specific connections
        org_query = (
            select(Connection)
            .options(selectinload(Connection.integration_credential))
            .where(
                Connection.integration_type == integration_type,
                Connection.organization_id == organization_id,
            )
        )
        org_result = await db.execute(org_query)
        org_connections = list(org_result.scalars().all())

        # Query for native connections of the same integration type
        native_query = (
            select(Connection)
            .options(selectinload(Connection.integration_credential))
            .where(
                Connection.integration_type == integration_type,
                Connection.organization_id.is_(None),
                or_(
                    *[
                        Connection.short_name == short_name
                        for short_name in self.NATIVE_CONNECTION_SHORT_NAMES
                    ]
                ),
            )
        )
        native_result = await db.execute(native_query)
        native_connections = list(native_result.scalars().all())

        # Combine the results
        return org_connections + native_connections
Get all active connections for a specific integration type, including native connections.

        This combines organization-specific connections with the system-level native connections.
        Native connections are included if they match the integration type.

        Args:
            db: The database session
            integration_type: The integration type to filter by
            organization_id: The organization ID

        Returns:
            A list of Connection objects including both organization connections and native ones
        
backend/airweave/crud/crud_connection.py