Function create_source

python/pathway/cli.py:576–586

(connection, image)

    '(see connectors list at: "https://hub.docker.com/search?q=airbyte%2Fsource-" )',
)
def create_source(connection, image):
    with optional_imports("airbyte"):
        from pathway.third_party.airbyte_serverless.connections import (
            ConnectionFromFile,
        )

    connection = ConnectionFromFile(connection)
    connection.init_yaml_config(image)
    click.echo(
        f"Connection `{connection.name}` with source `{image}` created successfully"
    )


def main() -> NoReturn: