Index

A

AIRFLOW_25_PLUS (in module astro.settings) api_client (astro.databases.databricks.delta.DeltaDatabase property) append() (in module astro.sql.operators.append) append_table() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) AppendOperator (class in astro.sql.operators.append) ASSUME_SCHEMA_EXISTS (in module astro.settings) astro module astro.airflow module astro.airflow.datasets module astro.constants module astro.custom_backend module astro.custom_backend.astro_custom_backend module astro.custom_backend.serializer module astro.databases module astro.databases.aws module astro.databases.aws.redshift module astro.databases.base module astro.databases.databricks module astro.databases.databricks.api_utils module astro.databases.databricks.delta module astro.databases.databricks.load_file module astro.databases.databricks.load_file.load_file_job module astro.databases.databricks.load_file.load_file_python_code_generator module astro.databases.databricks.load_options module astro.databases.duckdb module astro.databases.google module astro.databases.google.bigquery module astro.databases.mssql module astro.databases.mysql module astro.databases.postgres module astro.databases.snowflake module astro.databases.sqlite module astro.dataframes module astro.dataframes.load_options module astro.dataframes.pandas module astro.exceptions module astro.files module astro.files.base module astro.files.locations module astro.files.locations.amazon module astro.files.locations.amazon.s3 module astro.files.locations.azure module astro.files.locations.azure.wasb module astro.files.locations.base module astro.files.locations.ftp module astro.files.locations.google module astro.files.locations.google.gcs module astro.files.locations.google.gdrive module astro.files.locations.http module astro.files.locations.local module

astro.files.locations.sftp module astro.files.operators module astro.files.operators.files module astro.files.types module astro.files.types.base module astro.files.types.csv module astro.files.types.excel module astro.files.types.json module astro.files.types.ndjson module astro.files.types.parquet module astro.files.types.xls module astro.files.types.xlsx module astro.lineage module astro.lineage.facets module astro.options module astro.query_modifier module astro.settings module astro.sql module astro.sql.operators module astro.sql.operators.append module astro.sql.operators.base_decorator module astro.sql.operators.base_operator module astro.sql.operators.cleanup module astro.sql.operators.dataframe module astro.sql.operators.drop module astro.sql.operators.export_file module astro.sql.operators.export_table_to_file module astro.sql.operators.export_to_file module astro.sql.operators.load_file module astro.sql.operators.merge module astro.sql.operators.raw_sql module astro.sql.operators.transform module astro.sql.operators.upstream_task_mixin module astro.sql.table module astro.table module astro.utils module astro.utils.compat module astro.utils.compat.functools module astro.utils.compat.typing module astro.utils.dataframe module astro.utils.load module astro.utils.path module astro.utils.table module ASTRO_SDK_TO_SNOWFLAKE_FILE_FORMAT_MAP (in module astro.databases.snowflake) AstroCleanupException AstroCustomXcomBackend (class in astro.custom_backend.astro_custom_backend) AstroSDKConfigError AstroSQLBaseOperator (class in astro.sql.operators.base_operator) AUTO_ADD_INLETS_OUTLETS (in module astro.settings) AUTOLOADER (astro.constants.DatabricksLoadMode attribute) autoloader_load_options (astro.databases.databricks.load_options.DeltaLoadOptions attribute) AZURE (astro.constants.FileLocation attribute) AZURE_HOST (astro.files.locations.azure.wasb.WASBLocation attribute)

B

BaseDatabase (class in astro.databases.base) BaseFileLocation (class in astro.files.locations.base) BaseSQLDecoratedOperator (class in astro.sql.operators.base_decorator) BIGQUERY (astro.constants.Database attribute)

BIGQUERY_SCHEMA (in module astro.settings) BIGQUERY_SCHEMA_LOCATION (in module astro.settings) BIGQUERY_WRITE_DISPOSITION (in module astro.databases.google.bigquery) BigqueryDatabase (class in astro.databases.google.bigquery)

C

cache (in module astro.utils.compat.functools) check_column module check_column() (in module check_column) check_file_pattern_based_schema_autodetection_is_supported() (astro.databases.base.BaseDatabase method) check_for_minio_connection() (astro.databases.base.BaseDatabase static method) check_if_connection_exists() (in module astro.sql.operators.load_file) check_non_existing_local_file_path() (astro.files.locations.base.BaseFileLocation static method) check_schema_autodetection_is_supported() (astro.databases.base.BaseDatabase method) check_table module check_table() (in module check_table) cleanup() (in module astro.sql.operators.cleanup) CleanupOperator (class in astro.sql.operators.cleanup) ColumnCapitalization (in module astro.constants) ColumnCheckOperator (class in check_column) columns (astro.dataframes.load_options.PandasLoadOptions attribute) (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) (astro.lineage.facets.SourceTableMergeDatasetFacet attribute) (astro.lineage.facets.TableDatasetFacet attribute) (astro.lineage.facets.TargetTableMergeDatasetFacet attribute) columns_exist() (astro.databases.base.BaseDatabase method) conn_id (astro.files.base.File attribute) CONN_TYPE_TO_MODULE_PATH (in module astro.databases) connection (astro.databases.base.BaseDatabase property) connection() (astro.databases.duckdb.DuckdbDatabase method) contains_required_option() (in module astro.options) Context (class in astro.utils.compat.typing) convert_columns_names_capitalization() (in module astro.utils.dataframe) convert_copy_options_to_string() (astro.databases.databricks.load_options.DeltaLoadOptions method) convert_dataframe_to_file() (in module astro.utils.dataframe) convert_format_options_to_string() (astro.databases.databricks.load_options.DeltaLoadOptions method) COPY_INTO (astro.constants.DatabricksLoadMode attribute) COPY_INTO_COMMAND_FAIL_STATUS (in module astro.databases.snowflake) copy_into_copy_options (astro.databases.databricks.load_options.DeltaLoadOptions attribute) copy_into_format_options (astro.databases.databricks.load_options.DeltaLoadOptions attribute) copy_options (astro.options.SnowflakeLoadOptions attribute) copy_remote_file_to_local() (in module astro.utils.load) create_and_run_job() (in module astro.databases.databricks.api_utils)

create_database() (in module astro.databases) create_file_format() (astro.databases.snowflake.SnowflakeDatabase method) create_file_location() (in module astro.files.locations) create_file_type() (in module astro.files.types) create_from_dataframe() (astro.files.base.File method) (astro.files.types.base.FileType method) (astro.files.types.csv.CSVFileType method) (astro.files.types.excel.ExcelFileType method) (astro.files.types.json.JSONFileType method) (astro.files.types.ndjson.NDJSONFileType method) (astro.files.types.parquet.ParquetFileType method) create_output_table_if_needed() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) create_schema_if_applicable() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) create_schema_if_needed() (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.sqlite.SqliteDatabase method) create_secrets() (in module astro.databases.databricks.api_utils) create_stage() (astro.databases.snowflake.SnowflakeDatabase method) create_table() (astro.databases.base.BaseDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) create_table_from_select_statement() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.mssql.MssqlDatabase method) create_table_if_needed() (astro.databases.base.BaseDatabase method) create_table_using_columns() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) create_table_using_native_schema_autodetection() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) create_table_using_schema_autodetection() (astro.databases.base.BaseDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) create_transfer_config() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer method) CSV (astro.constants.FileType attribute) CSVFileType (class in astro.files.types.csv) CUSTOM_CONN_TYPE_TO_MODULE_PATH (in module astro.databases) cwd (in module astro.databases.databricks.api_utils) (in module astro.databases.databricks.load_file.load_file_job)

D

database (astro.table.Metadata attribute) Database (class in astro.constants) database_impl() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) DatabaseCustomError databricks_auth_settings() (astro.files.locations.amazon.s3.S3Location method) (astro.files.locations.azure.wasb.WASBLocation method) (astro.files.locations.base.BaseFileLocation method) (astro.files.locations.google.gcs.GCSLocation method) databricks_uri (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) DatabricksLoadMode (class in astro.constants) dataframe() (in module astro.sql.operators.dataframe) DATAFRAME_STORAGE_CONN_ID (in module astro.settings) DATAFRAME_STORAGE_URL (in module astro.settings) DataframeOperator (class in astro.sql.operators.dataframe) DATASET_SUPPORT (in module astro.airflow.datasets) DEFAULT_BIGQUERY_SCHEMA_LOCATION (in module astro.settings) DEFAULT_CHUNK_SIZE (in module astro.constants) DEFAULT_CONN_ID (in module astro.databases.aws.redshift) (in module astro.databases.duckdb) (in module astro.databases.google.bigquery) (in module astro.databases.mssql) (in module astro.databases.mysql) (in module astro.databases.postgres) (in module astro.databases.snowflake) (in module astro.databases.sqlite) DEFAULT_CONN_TYPE_TO_MODULE_PATH (in module astro.databases) DEFAULT_FILE_SCHEME_TO_MODULE_PATH (in module astro.files.locations) default_metadata (astro.databases.aws.redshift.RedshiftDatabase property) (astro.databases.base.BaseDatabase property) (astro.databases.databricks.delta.DeltaDatabase property) (astro.databases.duckdb.DuckdbDatabase property) (astro.databases.google.bigquery.BigqueryDatabase property) (astro.databases.mssql.MssqlDatabase property) (astro.databases.mysql.MysqlDatabase property) (astro.databases.postgres.PostgresDatabase property) (astro.databases.snowflake.SnowflakeDatabase property) (astro.databases.sqlite.SqliteDatabase property)

DEFAULT_SCHEMA (astro.databases.aws.redshift.RedshiftDatabase attribute) (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) (astro.databases.mssql.MssqlDatabase attribute) (astro.databases.mysql.MysqlDatabase attribute) (astro.databases.postgres.PostgresDatabase attribute) (astro.databases.snowflake.SnowflakeDatabase attribute) (in module astro.constants) DEFAULT_STORAGE_INTEGRATION (in module astro.databases.snowflake) delete_secret_scope() (in module astro.databases.databricks.api_utils) delete_transfer_config() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer method) delimiter (astro.dataframes.load_options.PandasLoadOptions attribute) DELTA (astro.constants.Database attribute) DeltaDatabase (class in astro.databases.databricks.delta) DeltaLoadOptions (class in astro.databases.databricks.load_options) DEPRECATED_LOAD_OPTIONS_CLASSES (in module astro.sql.operators.load_file) description (astro.lineage.facets.InputFileDatasetFacet attribute) (astro.lineage.facets.InputFileFacet attribute) (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) deserialize() (astro.constants.FileType static method) (astro.dataframes.pandas.PandasDataframe static method) (astro.sql.operators.raw_sql.SdkLegacyRow static method) (in module astro.custom_backend.serializer) deserialize_value() (astro.custom_backend.astro_custom_backend.AstroCustomXcomBackend static method) drop_stage() (astro.databases.snowflake.SnowflakeDatabase method) drop_table() (astro.databases.base.BaseDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.sql.operators.cleanup.CleanupOperator method) (in module astro.sql.operators.drop) DropTableOperator (class in astro.sql.operators.drop) dtype (astro.dataframes.load_options.PandasLoadOptions attribute) DUCKDB (astro.constants.Database attribute) DuckdbDatabase (class in astro.databases.duckdb)

E

empty() (astro.databases.databricks.load_options.DeltaLoadOptions method) (astro.options.LoadOptions method) (astro.options.SnowflakeLoadOptions method) ENABLE_XCOM_PICKLING (in module astro.settings) enabled_native_fallback (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) encoding (astro.dataframes.load_options.PandasLoadOptions attribute) ensure_internal_quotes_closed() (in module astro.databases.snowflake) ensure_only_valid_characters() (in module astro.databases.snowflake) evaluate_results() (astro.databases.snowflake.SnowflakeDatabase static method) ExcelFileType (class in astro.files.types.excel) execute() (astro.files.operators.files.ListFileOperator method) (astro.sql.operators.append.AppendOperator method) (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) (astro.sql.operators.cleanup.CleanupOperator method) (astro.sql.operators.dataframe.DataframeOperator method) (astro.sql.operators.drop.DropTableOperator method) (astro.sql.operators.export_to_file.ExportToFileOperator method) (astro.sql.operators.load_file.LoadFileOperator method) (astro.sql.operators.merge.MergeOperator method) (astro.sql.operators.raw_sql.RawSQLOperator method) (astro.sql.operators.transform.TransformOperator method) (check_column.ColumnCheckOperator method) (check_table.SQLCheckOperator method) existing_cluster_id (astro.databases.databricks.load_options.DeltaLoadOptions attribute)

exists() (astro.files.base.File method) (astro.files.locations.azure.wasb.WASBLocation method) (astro.files.locations.base.BaseFileLocation method) (astro.files.locations.google.gcs.GCSLocation method) export_file() (in module astro.sql.operators.export_file) export_table_to_file() (astro.databases.base.BaseDatabase method) (in module astro.sql.operators.export_table_to_file) export_table_to_pandas_dataframe() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) export_to_dataframe() (astro.files.base.File method) (astro.files.types.base.FileType method) (astro.files.types.csv.CSVFileType method) (astro.files.types.excel.ExcelFileType method) (astro.files.types.json.JSONFileType method) (astro.files.types.ndjson.NDJSONFileType method) (astro.files.types.parquet.ParquetFileType method) export_to_dataframe_via_byte_stream() (astro.files.base.File method) export_to_file() (in module astro.sql.operators.export_to_file) ExportExistsStrategy (in module astro.constants) ExportFileFacet (class in astro.lineage.facets) ExportFileOperator (class in astro.sql.operators.export_file) ExportTableToFileOperator (class in astro.sql.operators.export_table_to_file) ExportToFileOperator (class in astro.sql.operators.export_to_file) extra (astro.files.base.File attribute) (astro.table.Table attribute)

F

fetch_all_rows() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.mssql.MssqlDatabase method) File (class in astro.files.base) file_options (astro.options.SnowflakeLoadOptions attribute) FILE_PATTERN_BASED_AUTODETECT_SCHEMA_SUPPORTED (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) file_size (astro.lineage.facets.ExportFileFacet attribute) (astro.lineage.facets.InputFileFacet attribute) file_type (astro.databases.snowflake.SnowflakeFileFormat attribute) (astro.lineage.facets.ExportFileFacet attribute) (astro.lineage.facets.InputFileFacet attribute) FileLocation (class in astro.constants)

filepath (astro.lineage.facets.ExportFileFacet attribute) (astro.lineage.facets.InputFileFacet attribute) files (astro.lineage.facets.InputFileDatasetFacet attribute) filetype (astro.files.base.File attribute) FileType (class in astro.constants) (class in astro.files.types.base) filter_for_temp_tables() (in module astro.sql.operators.cleanup) find_first_table() (in module astro.utils.table) flatten() (astro.files.types.ndjson.NDJSONFileType static method) from_json() (astro.files.base.File class method) from_legacy_row() (astro.sql.operators.raw_sql.SdkLegacyRow static method) from_pandas_df() (astro.dataframes.pandas.PandasDataframe class method) FTP (astro.constants.FileLocation attribute) FTPLocation (class in astro.files.locations.ftp)

G

GCSLocation (class in astro.files.locations.google.gcs) GdriveLocation (class in astro.files.locations.google.gdrive) generate_file() (in module astro.databases.databricks.api_utils) get() (astro.options.LoadOptionsList method) get_all_task_outputs() (astro.sql.operators.cleanup.CleanupOperator method) get_by_class_name() (astro.options.LoadOptionsList method) get_check_result() (check_column.ColumnCheckOperator method) get_checks_string() (in module check_column) get_class_name() (in module astro.utils.path) get_dataframe_from_file() (astro.databases.base.BaseDatabase static method) (astro.databases.postgres.PostgresDatabase static method) get_db_hook() (check_column.ColumnCheckOperator method) (check_table.SQLCheckOperator method) get_default_delta_options() (astro.databases.databricks.load_options.DeltaLoadOptions class method) get_dict_with_module_names_to_dot_notations() (in module astro.utils.path) get_existing_cluster_id() (astro.databases.databricks.load_options.DeltaLoadOptions method) get_file_list() (in module astro.files) get_file_list_func() (in module astro.files.operators.files) get_filetype() (in module astro.files.types) get_handler() (astro.sql.operators.raw_sql.RawSQLOperator method) get_location_type() (astro.files.locations.base.BaseFileLocation static method) get_merge_initialization_query() (astro.databases.aws.redshift.RedshiftDatabase static method) (astro.databases.base.BaseDatabase static method) (astro.databases.databricks.delta.DeltaDatabase static method) (astro.databases.duckdb.DuckdbDatabase static method) (astro.databases.google.bigquery.BigqueryDatabase static method) (astro.databases.mssql.MssqlDatabase static method) (astro.databases.snowflake.SnowflakeDatabase class method) (astro.databases.sqlite.SqliteDatabase static method) get_module_dot_notation() (in module astro.utils.path) get_openlineage_facets_on_complete() (astro.sql.operators.append.AppendOperator method) (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) (astro.sql.operators.dataframe.DataframeOperator method) (astro.sql.operators.export_to_file.ExportToFileOperator method) (astro.sql.operators.load_file.LoadFileOperator method) (astro.sql.operators.merge.MergeOperator method)

get_project_id() (astro.databases.google.bigquery.BigqueryDatabase method) get_provider_info() (in module astro) get_results_format_handler() (astro.sql.operators.raw_sql.RawSQLOperator method) get_run_id() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer static method) get_snowflake_stage_auth_sub_statement() (astro.files.locations.amazon.s3.S3Location method) (astro.files.locations.base.BaseFileLocation method) get_source_code() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) (astro.sql.operators.dataframe.DataframeOperator method) get_sqla_table() (astro.databases.base.BaseDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.sqlite.SqliteDatabase method) get_sqlalchemy_template_table_identifier_and_parameter() (astro.databases.base.BaseDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) get_stream() (astro.files.locations.base.BaseFileLocation method) (astro.files.locations.ftp.FTPLocation method) (astro.files.locations.sftp.SFTPLocation method) get_table_qualified_name() (astro.databases.base.BaseDatabase static method) (astro.databases.duckdb.DuckdbDatabase static method) (astro.databases.mssql.MssqlDatabase static method) (astro.databases.mysql.MysqlDatabase static method) (astro.databases.postgres.PostgresDatabase static method) (astro.databases.snowflake.SnowflakeDatabase static method) (astro.databases.sqlite.SqliteDatabase static method) get_transfer_config_id() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer static method) get_transfer_info() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer method) get_uri() (astro.files.locations.ftp.FTPLocation method) (astro.files.locations.sftp.SFTPLocation method) get_value_list() (in module astro.sql) get_wrapped_handler() (astro.sql.operators.raw_sql.RawSQLOperator static method) GOOGLE_DRIVE (astro.constants.FileLocation attribute) GS (astro.constants.FileLocation attribute)

H

hook (astro.databases.databricks.delta.DeltaDatabase property) (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.sftp.SFTPLocation property) hook() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method)

HTTP (astro.constants.FileLocation attribute) HTTPLocation (class in astro.files.locations.http) HTTPS (astro.constants.FileLocation attribute)

I

if_conflicts (astro.lineage.facets.SourceTableMergeDatasetFacet attribute) if_exists (astro.databases.databricks.load_options.DeltaLoadOptions attribute) (astro.lineage.facets.ExportFileFacet attribute) illegal_column_name_chars (astro.databases.aws.redshift.RedshiftDatabase attribute) (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) (astro.databases.postgres.PostgresDatabase attribute) illegal_column_name_chars_replacement (astro.databases.aws.redshift.RedshiftDatabase attribute) (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) (astro.databases.postgres.PostgresDatabase attribute) IllegalLoadToDatabaseException InputFileDatasetFacet (class in astro.lineage.facets) InputFileFacet (class in astro.lineage.facets) is_autocommit_required() (astro.databases.mssql.MssqlDatabase method) IS_BASE_XCOM_BACKEND (in module astro.settings) is_binary() (astro.files.base.File method)

is_bytes (astro.files.base.File attribute) IS_CUSTOM_XCOM_BACKEND (in module astro.settings) is_dataframe (astro.files.base.File attribute) is_directory() (astro.files.base.File method) is_empty() (astro.table.Metadata method) is_local() (astro.files.base.File method) is_native_autodetect_schema_available() (astro.databases.base.BaseDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) is_native_load_file_available() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) is_newer_sqlalchemy() (in module astro.custom_backend.serializer) is_pattern (astro.lineage.facets.InputFileDatasetFacet attribute) is_pattern() (astro.files.base.File method) is_valid_path() (astro.files.locations.base.BaseFileLocation static method) is_valid_snow_identifier() (in module astro.databases.snowflake)

J

JSON (astro.constants.FileType attribute)

JSONFileType (class in astro.files.types.json)

K

kwargs (astro.dataframes.load_options.PandasLoadOptions attribute)

kwargs_with_datasets() (in module astro.airflow.datasets)

L

list_to_dict() (in module astro.options) ListFileOperator (class in astro.files.operators.files) load_data() (astro.sql.operators.load_file.LoadFileOperator method) load_data_to_dataframe() (astro.sql.operators.load_file.LoadFileOperator method) load_data_to_table() (astro.sql.operators.load_file.LoadFileOperator method) load_file() (in module astro.sql.operators.load_file) LOAD_FILE_ENABLE_NATIVE_FALLBACK (in module astro.settings) load_file_to_dbfs() (in module astro.databases.databricks.api_utils) load_file_to_delta() (in module astro.databases.databricks.load_file.load_file_job) load_file_to_table() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) load_file_to_table_natively() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) load_file_to_table_natively_with_fallback() (astro.databases.base.BaseDatabase method) load_file_to_table_using_pandas() (astro.databases.base.BaseDatabase method) load_gs_file_to_table() (astro.databases.google.bigquery.BigqueryDatabase method) load_local_file_to_table() (astro.databases.google.bigquery.BigqueryDatabase method) load_mode (astro.databases.databricks.load_options.DeltaLoadOptions attribute) load_op_arg_dataframes_into_sql() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) load_op_arg_table_into_dataframe() (in module astro.sql.operators.dataframe) load_op_kwarg_dataframes_into_sql() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) load_op_kwarg_table_into_dataframe() (in module astro.sql.operators.dataframe) load_options (astro.files.base.File property) LOAD_OPTIONS_CLASS_NAME (astro.databases.databricks.delta.DeltaDatabase attribute) (astro.databases.snowflake.SnowflakeDatabase attribute) (astro.files.locations.azure.wasb.WASBLocation attribute) (astro.files.types.csv.CSVFileType attribute) (astro.files.types.excel.ExcelFileType attribute) (astro.files.types.json.JSONFileType attribute) (astro.files.types.ndjson.NDJSONFileType attribute) (astro.files.types.parquet.ParquetFileType attribute)

load_options_list (astro.files.base.File property) load_pandas_dataframe_to_table() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) load_s3_file_to_table() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) load_secrets (astro.databases.databricks.load_options.DeltaLoadOptions attribute) LOAD_TABLE_AUTODETECT_ROWS_COUNT (in module astro.settings) LoadExistStrategy (in module astro.constants) LoadFileOperator (class in astro.sql.operators.load_file) LoadOptions (class in astro.options) LoadOptionsList (class in astro.options) LOCAL (astro.constants.FileLocation attribute) LocalLocation (class in astro.files.locations.local) location (astro.files.base.File property) location_type (astro.files.locations.amazon.s3.S3Location attribute) (astro.files.locations.azure.wasb.WASBLocation attribute) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation attribute) (astro.files.locations.google.gcs.GCSLocation attribute) (astro.files.locations.google.gdrive.GdriveLocation attribute) (astro.files.locations.http.HTTPLocation attribute) (astro.files.locations.local.LocalLocation attribute) (astro.files.locations.sftp.SFTPLocation attribute) log (in module astro.custom_backend.serializer) (in module astro.databases.databricks.api_utils) (in module astro.databases.databricks.load_file.load_file_job) (in module astro.lineage) logger (in module astro.dataframes.pandas)

M

make_row_serializable() (astro.sql.operators.raw_sql.RawSQLOperator static method) MappedOperator (in module astro.sql.operators.cleanup) MAX_DATAFRAME_MEMORY_FOR_XCOM_DB (in module astro.settings) MAX_TABLE_NAME_LENGTH (in module astro.table) merge() (in module astro.sql.operators.merge) merge_pre_and_post_queries() (astro.query_modifier.QueryModifier method) merge_table() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method) MergeConflictStrategy (in module astro.constants) MergeOperator (class in astro.sql.operators.merge) metadata (astro.databases.snowflake.SnowflakeStage attribute) (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) (astro.lineage.facets.SourceTableMergeDatasetFacet attribute) (astro.lineage.facets.TableDatasetFacet attribute) (astro.lineage.facets.TargetTableMergeDatasetFacet attribute) Metadata (class in astro.table) metadata_columns (astro.options.SnowflakeLoadOptions attribute) METADATA_COLUMNS_DATATYPE (astro.databases.snowflake.SnowflakeDatabase attribute) module astro astro.airflow astro.airflow.datasets astro.constants astro.custom_backend astro.custom_backend.astro_custom_backend astro.custom_backend.serializer astro.databases astro.databases.aws astro.databases.aws.redshift astro.databases.base astro.databases.databricks astro.databases.databricks.api_utils astro.databases.databricks.delta astro.databases.databricks.load_file astro.databases.databricks.load_file.load_file_job astro.databases.databricks.load_file.load_file_python_code_generator astro.databases.databricks.load_options astro.databases.duckdb astro.databases.google astro.databases.google.bigquery astro.databases.mssql astro.databases.mysql astro.databases.postgres astro.databases.snowflake astro.databases.sqlite astro.dataframes astro.dataframes.load_options astro.dataframes.pandas astro.exceptions astro.files astro.files.base astro.files.locations astro.files.locations.amazon astro.files.locations.amazon.s3 astro.files.locations.azure astro.files.locations.azure.wasb astro.files.locations.base astro.files.locations.ftp astro.files.locations.google astro.files.locations.google.gcs astro.files.locations.google.gdrive astro.files.locations.http astro.files.locations.local astro.files.locations.sftp astro.files.operators astro.files.operators.files astro.files.types astro.files.types.base astro.files.types.csv astro.files.types.excel astro.files.types.json astro.files.types.ndjson astro.files.types.parquet astro.files.types.xls astro.files.types.xlsx astro.lineage astro.lineage.facets astro.options astro.query_modifier astro.settings astro.sql astro.sql.operators astro.sql.operators.append astro.sql.operators.base_decorator astro.sql.operators.base_operator astro.sql.operators.cleanup astro.sql.operators.dataframe astro.sql.operators.drop astro.sql.operators.export_file astro.sql.operators.export_table_to_file astro.sql.operators.export_to_file astro.sql.operators.load_file astro.sql.operators.merge astro.sql.operators.raw_sql astro.sql.operators.transform astro.sql.operators.upstream_task_mixin astro.sql.table astro.table astro.utils astro.utils.compat astro.utils.compat.functools astro.utils.compat.typing astro.utils.dataframe astro.utils.load astro.utils.path astro.utils.table check_column check_table

move_function_params_into_sql_params() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) msg (astro.sql.operators.cleanup.AstroCleanupException attribute) MSSQL (astro.constants.Database attribute) MSSQL_SCHEMA (in module astro.settings) MssqlDatabase (class in astro.databases.mssql) MYSQL (astro.constants.Database attribute) MYSQL_SCHEMA (in module astro.settings) MysqlDatabase (class in astro.databases.mysql)

N

name (astro.databases.snowflake.SnowflakeFileFormat attribute) (astro.databases.snowflake.SnowflakeStage attribute) (astro.files.types.base.FileType property) (astro.files.types.csv.CSVFileType property) (astro.files.types.json.JSONFileType property) (astro.files.types.ndjson.NDJSONFileType property) (astro.files.types.parquet.ParquetFileType property) (astro.files.types.xls.XLSFileType property) (astro.files.types.xlsx.XLSXFileType property) NATIVE_AUTODETECT_SCHEMA_CONFIG (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) NATIVE_AUTODETECT_SCHEMA_SUPPORTED_FILE_LOCATIONS (in module astro.databases.snowflake) NATIVE_AUTODETECT_SCHEMA_SUPPORTED_FILE_TYPES (in module astro.databases.snowflake) NATIVE_LOAD_EXCEPTIONS (astro.databases.aws.redshift.RedshiftDatabase attribute) (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) (astro.databases.snowflake.SnowflakeDatabase attribute)

NATIVE_LOAD_SUPPORTED_FILE_LOCATIONS (in module astro.databases.snowflake) NATIVE_LOAD_SUPPORTED_FILE_TYPES (in module astro.databases.snowflake) NATIVE_PATHS (astro.databases.aws.redshift.RedshiftDatabase attribute) (astro.databases.base.BaseDatabase attribute) (astro.databases.google.bigquery.BigqueryDatabase attribute) NATIVE_PATHS_SUPPORTED_FILE_TYPES (in module astro.databases.aws.redshift) (in module astro.databases.google.bigquery) native_support_arguments (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) NDJSON (astro.constants.FileType attribute) NDJSONFileType (class in astro.files.types.ndjson) NEED_CUSTOM_SERIALIZATION (in module astro.settings) new_cluster_spec (astro.databases.databricks.load_options.DeltaLoadOptions attribute) NonExistentTableException normalize_config (astro.files.base.File attribute) normalize_sep (astro.dataframes.load_options.PandasLoadOptions attribute) number_of_files (astro.lineage.facets.InputFileDatasetFacet attribute)

O

OPENLINEAGE_AIRFLOW_DISABLE_SOURCE_CODE (in module astro.settings) openlineage_dataset_name (astro.files.base.File property) (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.http.HTTPLocation property) (astro.files.locations.local.LocalLocation property) (astro.files.locations.sftp.SFTPLocation property) openlineage_dataset_name() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method) openlineage_dataset_namespace (astro.files.base.File property) (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.http.HTTPLocation property) (astro.files.locations.local.LocalLocation property) (astro.files.locations.sftp.SFTPLocation property)

openlineage_dataset_namespace() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method) openlineage_dataset_uri() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method) OPENLINEAGE_EMIT_TEMP_TABLE_EVENT (in module astro.settings) OPERATOR_CLASSES_WITH_TABLE_OUTPUT (in module astro.sql.operators.cleanup) OutputDatabaseDatasetFacet (class in astro.lineage.facets)

P

PandasCsvLoadOptions (class in astro.dataframes.load_options) PandasDataframe (class in astro.dataframes.pandas) PandasJsonLoadOptions (class in astro.dataframes.load_options) PandasLoadOptions (class in astro.dataframes.load_options) PandasNdjsonLoadOptions (class in astro.dataframes.load_options) PandasParquetLoadOptions (class in astro.dataframes.load_options) parameterize_variable() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) PARQUET (astro.constants.FileType attribute) ParquetFileType (class in astro.files.types.parquet) path (astro.files.base.File attribute) paths (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.http.HTTPLocation property) (astro.files.locations.local.LocalLocation property) (astro.files.locations.sftp.SFTPLocation property)

PermissionNotSetError populate_kwargs() (astro.dataframes.load_options.PandasLoadOptions method) populate_table_metadata() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.duckdb.DuckdbDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.sqlite.SqliteDatabase method) POSTGRES (astro.constants.Database attribute) POSTGRES_SCHEMA (in module astro.settings) PostgresDatabase (class in astro.databases.postgres) POSTGRESQL (astro.constants.Database attribute) process_checks() (check_column.ColumnCheckOperator method) PYPI_PROJECT_NAME (in module astro.constants)

Q

qualified_name (astro.databases.snowflake.SnowflakeStage property)

QueryModifier (class in astro.query_modifier)

R

RAW_SQL_MAX_RESPONSE_SIZE (in module astro.settings) RawSQLOperator (class in astro.sql.operators.raw_sql) read_sql_from_function() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) REDSHIFT (astro.constants.Database attribute) REDSHIFT_SCHEMA (in module astro.settings) RedshiftDatabase (class in astro.databases.aws.redshift) reload() (in module astro.settings) render() (in module astro.databases.databricks.load_file.load_file_python_code_generator) render_template_fields() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) resolve_file_path_pattern() (in module astro.files.base) resolve_tables_from_tasks() (astro.sql.operators.cleanup.CleanupOperator method)

results_as_list() (astro.sql.operators.raw_sql.RawSQLOperator static method) results_as_pandas_dataframe() (astro.sql.operators.raw_sql.RawSQLOperator static method) row_count() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) run() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer method) run_raw_sql() (in module astro.sql.operators.raw_sql) run_single_sql_query() (astro.databases.base.BaseDatabase method) run_sql() (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.mssql.MssqlDatabase method) run_transfer_now() (astro.databases.google.bigquery.S3ToBigqueryDataTransfer method) RunRawSQLResultFormat (in module astro.constants)

S

S3 (astro.constants.FileLocation attribute) S3Location (class in astro.files.locations.amazon.s3) S3ToBigqueryDataTransfer (class in astro.databases.google.bigquery) schema (astro.lineage.facets.OutputDatabaseDatasetFacet attribute) (astro.table.Metadata attribute) SCHEMA (in module astro.settings) schema_exists() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) (astro.databases.snowflake.SnowflakeDatabase method) (astro.databases.sqlite.SqliteDatabase method) SdkLegacyRow (class in astro.sql.operators.raw_sql) secret_scope (astro.databases.databricks.load_options.DeltaLoadOptions attribute) SECTION_KEY (in module astro.settings) serialize() (astro.constants.FileType method) (astro.dataframes.pandas.PandasDataframe method) (astro.sql.operators.raw_sql.SdkLegacyRow method) (in module astro.custom_backend.serializer) serialize_value() (astro.custom_backend.astro_custom_backend.AstroCustomXcomBackend static method) set_file_type_from_file() (astro.databases.snowflake.SnowflakeFileFormat method) set_url_from_file() (astro.databases.snowflake.SnowflakeStage method) SFTP (astro.constants.FileLocation attribute) sftp_stream() (astro.files.locations.sftp.SFTPLocation method) SFTPLocation (class in astro.files.locations.sftp) size (astro.files.base.File property) (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.http.HTTPLocation property) (astro.files.locations.local.LocalLocation property) (astro.files.locations.sftp.SFTPLocation property) smartopen_uri (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) SNOWFLAKE (astro.constants.Database attribute) SNOWFLAKE_SCHEMA (in module astro.settings) snowflake_stage_path (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property)

SNOWFLAKE_STORAGE_INTEGRATION_AMAZON (in module astro.settings) SNOWFLAKE_STORAGE_INTEGRATION_GOOGLE (in module astro.settings) SnowflakeDatabase (class in astro.databases.snowflake) SnowflakeFileFormat (class in astro.databases.snowflake) SnowflakeLoadOptions (class in astro.options) SnowflakeStage (class in astro.databases.snowflake) source_table_rows (astro.lineage.facets.SourceTableMergeDatasetFacet attribute) (astro.lineage.facets.TableDatasetFacet attribute) SourceTableMergeDatasetFacet (class in astro.lineage.facets) sql_type (astro.databases.aws.redshift.RedshiftDatabase property) (astro.databases.base.BaseDatabase property) (astro.databases.databricks.delta.DeltaDatabase property) (astro.databases.duckdb.DuckdbDatabase property) (astro.databases.google.bigquery.BigqueryDatabase property) (astro.databases.mssql.MssqlDatabase property) (astro.databases.mysql.MysqlDatabase property) (astro.databases.postgres.PostgresDatabase property) (astro.databases.snowflake.SnowflakeDatabase property) (astro.databases.sqlite.SqliteDatabase property) sqlalchemy_engine (astro.databases.databricks.delta.DeltaDatabase property) sqlalchemy_engine() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.google.bigquery.BigqueryDatabase method) (astro.databases.sqlite.SqliteDatabase method) SQLCheckOperator (class in check_table) SQLITE (astro.constants.Database attribute) SqliteDatabase (class in astro.databases.sqlite) stage_exists() (astro.databases.snowflake.SnowflakeDatabase method) storage_account (astro.options.WASBLocationLoadOptions attribute) storage_integration (astro.options.SnowflakeLoadOptions attribute) STORE_DATA_LOCAL_DEV (in module astro.settings) supported_conn_type (astro.files.locations.amazon.s3.S3Location attribute) (astro.files.locations.azure.wasb.WASBLocation attribute) (astro.files.locations.base.BaseFileLocation attribute) (astro.files.locations.ftp.FTPLocation attribute) (astro.files.locations.google.gcs.GCSLocation attribute) (astro.files.locations.google.gdrive.GdriveLocation attribute) (astro.files.locations.sftp.SFTPLocation attribute) SUPPORTED_DATABASES (in module astro.constants) (in module astro.databases) SUPPORTED_FILE_LOCATIONS (in module astro.constants) supported_file_locations (in module astro.databases.databricks.load_file.load_file_job) SUPPORTED_FILE_TYPES (in module astro.constants)

T

Table (class in astro.table) table_exists() (astro.databases.aws.redshift.RedshiftDatabase method) (astro.databases.base.BaseDatabase method) (astro.databases.databricks.delta.DeltaDatabase method) (astro.databases.mssql.MssqlDatabase method) (astro.databases.mysql.MysqlDatabase method) (astro.databases.postgres.PostgresDatabase method) table_name (astro.lineage.facets.SourceTableMergeDatasetFacet attribute) (astro.lineage.facets.TableDatasetFacet attribute) (astro.lineage.facets.TargetTableMergeDatasetFacet attribute) TableDatasetFacet (class in astro.lineage.facets) target_conflict_columns (astro.lineage.facets.TargetTableMergeDatasetFacet attribute) TargetTableMergeDatasetFacet (class in astro.lineage.facets) TEMP_PREFIX (in module astro.table) template_ext (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator attribute) template_fields (astro.files.base.File attribute) (astro.files.locations.base.BaseFileLocation attribute) (astro.files.operators.files.ListFileOperator attribute) (astro.sql.operators.append.AppendOperator attribute) (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator attribute) (astro.sql.operators.cleanup.CleanupOperator attribute) (astro.sql.operators.drop.DropTableOperator attribute) (astro.sql.operators.export_file.ExportFileOperator attribute) (astro.sql.operators.export_table_to_file.ExportTableToFileOperator attribute) (astro.sql.operators.export_to_file.ExportToFileOperator attribute) (astro.sql.operators.load_file.LoadFileOperator attribute) (astro.sql.operators.merge.MergeOperator attribute) (check_table.SQLCheckOperator attribute)

to_dict() (astro.options.LoadOptions method) to_json() (astro.files.base.File method) transform() (in module astro.sql.operators.transform) transform_file() (in module astro.sql.operators.transform) TransformOperator (class in astro.sql.operators.transform) translate_jinja_to_sqlalchemy_template() (astro.sql.operators.base_decorator.BaseSQLDecoratedOperator method) transport_params (astro.files.locations.amazon.s3.S3Location property) (astro.files.locations.azure.wasb.WASBLocation property) (astro.files.locations.base.BaseFileLocation property) (astro.files.locations.ftp.FTPLocation property) (astro.files.locations.google.gcs.GCSLocation property) (astro.files.locations.google.gdrive.GdriveLocation property) (astro.files.locations.sftp.SFTPLocation property) truncate_table() (astro.databases.snowflake.SnowflakeDatabase method) type (astro.files.base.File property)

U

UpstreamTaskMixin (class in astro.sql.operators.upstream_task_mixin) uri (astro.files.base.File attribute) (astro.table.Table attribute)

url (astro.databases.snowflake.SnowflakeStage attribute) use_quotes() (astro.databases.snowflake.SnowflakeDatabase class method) used_native_path (astro.lineage.facets.OutputDatabaseDatasetFacet attribute)

V

validate_conn() (astro.files.locations.base.BaseFileLocation method) (astro.files.locations.http.HTTPLocation method) (astro.files.locations.local.LocalLocation method)

validation_mode (astro.options.SnowflakeLoadOptions attribute) version (astro.dataframes.pandas.PandasDataframe attribute) (astro.sql.operators.raw_sql.SdkLegacyRow attribute)

W

wait_for_dag_to_finish() (astro.sql.operators.cleanup.CleanupOperator method) WASB (astro.constants.FileLocation attribute) WASBLocation (class in astro.files.locations.azure.wasb) WASBLocationException

WASBLocationLoadOptions (class in astro.options) WASBS (astro.constants.FileLocation attribute) wrap_identifier() (in module astro.databases.mssql) (in module astro.databases.snowflake)

X

XCOM_BACKEND (in module astro.settings) XLS (astro.constants.FileType attribute)

XLSFileType (class in astro.files.types.xls) XLSX (astro.constants.FileType attribute) XLSXFileType (class in astro.files.types.xlsx)