QueryAsset

class great_expectations.datasource.fluent.sql_datasource.QueryAsset(*, name: str, type: typing.Literal['query'] = 'query', id: <pydantic.v1.fields.DeferredType object at 0x7efbc2c7f6e0> = None, order_by: <pydantic.v1.fields.DeferredType object at 0x7efbc2c7f710> = None, batch_metadata: <pydantic.v1.fields.DeferredType object at 0x7efbc2c7f860> = None, batch_definitions: <pydantic.v1.fields.DeferredType object at 0x7efbc2c7fa10> = None, query: str)#

add_batch_definition_daily(name: str, column: str, sort_ascending: bool = True, validate_batchable: bool = True) → BatchDefinition#

add_batch_definition_monthly(name: str, column: str, sort_ascending: bool = True, validate_batchable: bool = True) → BatchDefinition#

add_batch_definition_whole_table(name: str)→ BatchDefinition#

add_batch_definition_yearly(name: str, column: str, sort_ascending: bool = True, validate_batchable: bool = True) → BatchDefinition#

delete_batch_definition(name: str)→ None#

Delete a batch definition.

Parameters

name (str) – Name of the BatchDefinition to delete.

get_batch_definition(name: str)→ great_expectations.core.batch_definition.BatchDefinition#

Get a batch definition.

Parameters

name (str) – Name of the BatchDefinition to get.

Raises

KeyError – If the BatchDefinition does not exist.

validate_batch_definition(partitioner: Union[great_expectations.core.partitioners.PartitionerColumnValue, great_expectations.core.partitioners.PartitionerMultiColumnValue, great_expectations.core.partitioners.PartitionerDividedInteger, great_expectations.core.partitioners.PartitionerModInteger, great_expectations.core.partitioners.ColumnPartitionerYearly, great_expectations.core.partitioners.ColumnPartitionerMonthly, great_expectations.core.partitioners.ColumnPartitionerDaily, great_expectations.core.partitioners.PartitionerDatetimePart, great_expectations.core.partitioners.PartitionerConvertedDatetime])→ None#

Validates that the batch definition column is of a permissible type

This isn’t meant to be called directly. This is called internally when a batch definition

is added. Data asset implementers can override this for their specific data asset.

Raises

SqlAddBatchDefinitionError – The specified column to partition on is not of a permissible type for batching (ie date or datetime) or no data is present in this column.