src/astro/sql/operators/agnostic_save_file.py
def save_file(
    output_file_path,
    input=None,
    output_conn_id=None,
    overwrite=False,
    output_file_format="csv",
    task_id=None,
    **kwargs,
):
    """Convert SaveFile into a function. Returns XComArg.

    Returns an XComArg object.

    :param output_file_path: Path and name of table to create.
    :type output_file_path: str
    :param table: Input table name.
    :type table: str
    :param input_conn_id: Database connection id.
    :type input_conn_id: str
    :param output_conn_id: File system connection id (if S3 or GCS).
    :type output_conn_id: str
    :param overwrite: Overwrite file if exists. Default False.
    :type overwrite: bool
    :param task_id: task id, optional.
    :type task_id: str
    """

    task_id = (
        task_id if task_id is not None else get_task_id("save_file", output_file_path)
    )

    return SaveFile(
        task_id=task_id,
        output_file_path=output_file_path,
        input=input,
        output_conn_id=output_conn_id,
        overwrite=overwrite,
        output_file_format=output_file_format,
    ).output
Convert SaveFile into a function. Returns XComArg.

    Returns an XComArg object.

    :param output_file_path: Path and name of table to create.
    :type output_file_path: str
    :param table: Input table name.
    :type table: str
    :param input_conn_id: Database connection id.
    :type input_conn_id: str
    :param output_conn_id: File system connection id (if S3 or GCS).
    :type output_conn_id: str
    :param overwrite: Overwrite file if exists. Default False.
    :type overwrite: bool
    :param task_id: task id, optional.
    :type task_id: str
    
Convert SaveFile into a function.
Convert SaveFile into a function .
def save_file(
    output_file_path,
    input=None,
    output_conn_id=None,
    overwrite=False,
    output_file_format="csv",
    task_id=None,
    **kwargs,
):
    task_id = (
        task_id if task_id is not None else get_task_id("save_file", output_file_path)
    )
    return SaveFile(
        task_id=task_id,
        output_file_path=output_file_path,
        input=input,
        output_conn_id=output_conn_id,
        overwrite=overwrite,
        output_file_format=output_file_format,
    ).output
def save_file ( output_file_path , input = None , output_conn_id = None , overwrite = False , output_file_format = "csv" , task_id = None , ** kwargs , ) : task_id = ( task_id if task_id is not None else get_task_id ( "save_file" , output_file_path ) ) return SaveFile ( task_id = task_id , output_file_path = output_file_path , input = input , output_conn_id = output_conn_id , overwrite = overwrite , output_file_format = output_file_format , ) . output
Convert SaveFile into a function.
Convert SaveFile into a function .
"""Convert SaveFile into a function. Returns XComArg.

    Returns an XComArg object.

    :param output_file_path: Path and name of table to create.
    :type output_file_path: str
    :param table: Input table name.
    :type table: str
    :param input_conn_id: Database connection id.
    :type input_conn_id: str
    :param output_conn_id: File system connection id (if S3 or GCS).
    :type output_conn_id: str
    :param overwrite: Overwrite file if exists. Default False.
    :type overwrite: bool
    :param task_id: task id, optional.
    :type task_id: str
    """
output_file_path
Path and name of table to create.
Path and name of table to create .
input
output_conn_id
File system connection id (if S3 or GCS).
File system connection id ( if S3 or GCS ) .
overwrite
Overwrite file if exists. Default False.
Overwrite file if exists . Default False .
output_file_format
task_id
task id, optional.
task id optional .
table
Input table name.
Input table name .
input_conn_id
Database connection id.
Database connection id .