Query Tasks

These are sub-tasks that query planners can produce and wrap into either a SequentialExecutor or a ParallelExecutor implementations.

amsdal_glue.tasks.SchemaQueryTask dataclass

Bases: Task

SchemaQueryTask is responsible for executing a schema query node. It extends the Task class.

Attributes:

Name	Type	Description
schema_query_node	SchemaQueryNode	The schema query node to be executed.

execute

execute(transaction_id, lock_id)

Executes the schema query node.

Parameters:

Name	Type	Description	Default
transaction_id	str | None	The ID of the transaction.	required
lock_id	str | None	The ID of the lock.	required

item property

item

Returns the schema query node.

Returns:

Name	Type	Description
Any	Any	The schema query node.

result property

result

Returns the result of the schema query node execution.

Returns:

Type	Description
list[Schema] | None	list[Schema] | None: The result of the schema query node execution.

amsdal_glue.tasks.FinalSchemaQueryTask

Bases: Task

FinalSchemaQueryTask is responsible for executing a final schema query node. It extends the Task class.

Attributes:

Name	Type	Description
tasks	list[SchemaQueryTask]	The list of schema query tasks to be executed.
_results	list[Schema]	The results of the schema query tasks execution.

item property

item

Returns the list of schema query nodes.

Returns:

Name	Type	Description
Any	Any	The list of schema query nodes.

result property

result

Returns the results of the schema query tasks execution.

Returns:

Type	Description
list[Schema]	list[Schema]: The results of the schema query tasks execution.

execute

execute(transaction_id, lock_id)

Executes the final schema query tasks.

Parameters:

Name	Type	Description	Default
transaction_id	str | None	The ID of the transaction.	required
lock_id	str | None	The ID of the lock.	required

amsdal_glue.tasks.DataQueryTask

Bases: Task

DataQueryTask is responsible for executing a data query node. It extends the Task class.

Attributes:

Name	Type	Description
query_node	DataQueryNode	The data query node to be executed.
executor	DataQueryNodeExecutor	The executor responsible for executing the data query node.

execute

execute(transaction_id, lock_id)

Executes the data query node.

Parameters:

Name	Type	Description	Default
transaction_id	str | None	The ID of the transaction.	required
lock_id	str | None	The ID of the lock.	required

item property

item

Returns the data query node.

Returns:

Name	Type	Description
Any	Any	The data query node.

result property

result

Returns the result of the data query node execution.

Returns:

Name	Type	Description
Any	Any	The result of the data query node execution.

amsdal_glue.tasks.FinalDataQueryTask

Bases: Task

FinalDataQueryTask is responsible for executing a final data query node. It extends the Task class.

Attributes:

Name	Type	Description
query_node	FinalDataQueryNode	The final data query node to be executed.
executor	FinalDataQueryExecutor	The executor responsible for executing the final data query node.

execute

execute(transaction_id, lock_id)

Executes the final data query node.

Parameters:

Name	Type	Description	Default
transaction_id	str | None	The ID of the transaction.	required
lock_id	str | None	The ID of the lock.	required

item property

item

Returns the final data query node.

Returns:

Name	Type	Description
Any	Any	The final data query node.

result property

result

Returns the result of the final data query node execution.

Returns:

Name	Type	Description
Any	Any	The result of the final data query node execution.