Back to Prefect

abstract

docs/v3/api-ref/python/prefect-blocks-abstract.mdx

3.6.30.dev3135.3 KB
Original Source

prefect.blocks.abstract

Classes

CredentialsBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L37" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Stores credentials for an external system and exposes a client for interacting with that system. Can also hold config that is tightly coupled to credentials (domain, endpoint, account ID, etc.) Will often be composed with other blocks. Parent block should rely on the client provided by a credentials block for interacting with the corresponding external system.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_client <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L63" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_client(self, *args: Any, **kwargs: Any) -> Any

Returns a client for interacting with the external system.

If a service offers various clients, this method can accept a client_type keyword argument to get the desired client within the service.

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L47" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the CredentialsBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

NotificationError <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L73" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Raised if a notification block fails to send a notification.

NotificationBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L80" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Block that represents a resource in an external system that is able to send notifications.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L89" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the NotificationBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

notify <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L105" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
notify(self, body: str, subject: str | None = None) -> None

Send a notification.

Args:

  • body: The body of the notification.
  • subject: The subject of the notification.

raise_on_failure <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L117" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
raise_on_failure(self) -> Generator[None, None, None]

Context manager that, while active, causes the block to raise errors if it encounters a failure sending notifications.

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

JobRun <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L129" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Represents a job run in an external system. Allows waiting for the job run's completion and fetching its results.

Methods:

fetch_result <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L158" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
fetch_result(self) -> T

Retrieve the results of the job run and return them.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L136" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the JobRun is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

wait_for_completion <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L152" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
wait_for_completion(self) -> Logger

Wait for the job run to complete.

JobBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L164" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Block that represents an entity in an external service that can trigger a long running execution.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L171" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the JobBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

trigger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L187" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
trigger(self) -> JobRun[T]

Triggers a job run in an external service and returns a JobRun object to track the execution of the run.

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

DatabaseBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L199" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

An abstract block type that represents a database and provides an interface for interacting with it.

Blocks that implement this interface have the option to accept credentials directly via attributes or via a nested CredentialsBlock.

Use of a nested credentials block is recommended unless credentials are tightly coupled to database connection configuration.

Implementing either sync or async context management on DatabaseBlock implementations is recommended.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

execute <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L293" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
execute(self, operation: str, parameters: dict[str, Any] | None = None, **execution_kwargs: Any) -> None

Executes an operation on the database. This method is intended to be used for operations that do not return data, such as INSERT, UPDATE, or DELETE.

Args:

  • operation: The SQL query or other operation to be executed.
  • parameters: The parameters for the operation.
  • **execution_kwargs: Additional keyword arguments to pass to execute.

execute_many <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L310" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
execute_many(self, operation: str, seq_of_parameters: list[dict[str, Any]], **execution_kwargs: Any) -> None

Executes multiple operations on the database. This method is intended to be used for operations that do not return data, such as INSERT, UPDATE, or DELETE.

Args:

  • operation: The SQL query or other operation to be executed.
  • seq_of_parameters: The sequence of parameters for the operation.
  • **execution_kwargs: Additional keyword arguments to pass to execute.

fetch_all <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L273" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
fetch_all(self, operation: str, parameters: dict[str, Any] | None = None, **execution_kwargs: Any) -> list[tuple[Any, ...]]

Fetch all results from the database.

Args:

  • operation: The SQL query or other operation to be executed.
  • parameters: The parameters for the operation.
  • **execution_kwargs: Additional keyword arguments to pass to execute.

Returns:

  • A list of tuples containing the data returned by the database, where each row is a tuple and each column is a value in the tuple.

fetch_many <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L251" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
fetch_many(self, operation: str, parameters: dict[str, Any] | None = None, size: int | None = None, **execution_kwargs: Any) -> list[tuple[Any, ...]]

Fetch a limited number of results from the database.

Args:

  • operation: The SQL query or other operation to be executed.
  • parameters: The parameters for the operation.
  • size: The number of results to return.
  • **execution_kwargs: Additional keyword arguments to pass to execute.

Returns:

  • A list of tuples containing the data returned by the database, where each row is a tuple and each column is a value in the tuple.

fetch_one <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L231" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
fetch_one(self, operation: str, parameters: dict[str, Any] | None = None, **execution_kwargs: Any) -> tuple[Any, ...]

Fetch a single result from the database.

Args:

  • operation: The SQL query or other operation to be executed.
  • parameters: The parameters for the operation.
  • **execution_kwargs: Additional keyword arguments to pass to execute.

Returns:

  • A list of tuples containing the data returned by the database, where each row is a tuple and each column is a value in the tuple.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L215" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the DatabaseBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

ObjectStorageBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L361" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Block that represents a resource in an external service that can store objects.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

download_folder_to_path <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L423" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
download_folder_to_path(self, from_folder: str, to_folder: str | Path, **download_kwargs: Any) -> Path

Downloads a folder from the object storage service to a path.

Args:

  • from_folder: The path to the folder to download from.
  • to_folder: The path to download the folder to.
  • **download_kwargs: Additional keyword arguments to pass to download.

Returns:

  • The path that the folder was downloaded to.

download_object_to_file_object <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L403" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
download_object_to_file_object(self, from_path: str, to_file_object: BinaryIO, **download_kwargs: Any) -> BinaryIO

Downloads an object from the object storage service to a file-like object, which can be a BytesIO object or a BufferedWriter.

Args:

  • from_path: The path to download from.
  • to_file_object: The file-like object to download to.
  • **download_kwargs: Additional keyword arguments to pass to download.

Returns:

  • The file-like object that the object was downloaded to.

download_object_to_path <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L384" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
download_object_to_path(self, from_path: str, to_path: str | Path, **download_kwargs: Any) -> Path

Downloads an object from the object storage service to a path.

Args:

  • from_path: The path to download from.
  • to_path: The path to download to.
  • **download_kwargs: Additional keyword arguments to pass to download.

Returns:

  • The path that the object was downloaded to.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L368" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the ObjectStorageBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

upload_from_file_object <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L458" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
upload_from_file_object(self, from_file_object: BinaryIO, to_path: str, **upload_kwargs: Any) -> str

Uploads an object to the object storage service from a file-like object, which can be a BytesIO object or a BufferedReader.

Args:

  • from_file_object: The file-like object to upload from.
  • to_path: The path to upload the object to.
  • **upload_kwargs: Additional keyword arguments to pass to upload.

Returns:

  • The path that the object was uploaded to.

upload_from_folder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L475" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
upload_from_folder(self, from_folder: str | Path, to_folder: str, **upload_kwargs: Any) -> str

Uploads a folder to the object storage service from a path.

Args:

  • from_folder: The path to the folder to upload from.
  • to_folder: The path to upload the folder to.
  • **upload_kwargs: Additional keyword arguments to pass to upload.

Returns:

  • The path that the folder was uploaded to.

upload_from_path <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
upload_from_path(self, from_path: str | Path, to_path: str, **upload_kwargs: Any) -> str

Uploads an object from a path to the object storage service.

Args:

  • from_path: The path to the file to upload from.
  • to_path: The path to upload the file to.
  • **upload_kwargs: Additional keyword arguments to pass to upload.

Returns:

  • The path that the object was uploaded to.

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

SecretBlock <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L494" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

Block that represents a resource that can store and retrieve secrets.

Methods:

adelete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1893" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
adelete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Asynchronously deletes the block document with the specified name.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected.

aload <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1057" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling aload, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Custom.aload("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = await Block.aload("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = await Custom.aload("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

aload_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1244" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aload_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Asynchronously retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling aload_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, aload_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

annotation_refers_to_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1442" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
annotation_refers_to_block_class(annotation: Any) -> bool

aregister_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1455" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
aregister_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Asynchronously makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided.

asave <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1842" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
asave(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Asynchronously saves the values of a block as a block document.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected.

Returns:

  • The ID of the saved block document.

block_initialization <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L381" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
block_initialization(self) -> None

delete <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1914" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
delete(cls, name: str, client: Optional['PrefectClient'] = None) -> None

Deletes the block document with the specified name.

This function will dispatch to adelete when called from an async context.

Args:

  • name: The name of the block document to delete.
  • client: The client to use to delete the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

get_block_capabilities <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L477" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_capabilities(cls) -> FrozenSet[str]

Returns the block capabilities for this Block. Recursively collects all block capabilities of all parent classes into a single frozenset.

get_block_class_from_key <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L902" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_key(cls: type[Self], key: str) -> type[Self]

Retrieve the block class implementation given a key.

get_block_class_from_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L895" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_class_from_schema(cls: type[Self], schema: BlockSchema) -> type[Self]

Retrieve the block class implementation given a schema.

get_block_placeholder <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1934" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_placeholder(self) -> str

Returns the block placeholder for the current block which can be used for templating.

Returns:

  • The block placeholder for the current block in the format prefect.blocks.{block_type_name}.{block_document_name}

Raises:

  • BlockNotSavedError: Raised if the block has not been saved.

If a block has not been saved, the return value will be None.

get_block_schema_version <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L507" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_schema_version(cls) -> str

get_block_type_name <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L469" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_name(cls) -> str

get_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L473" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_block_type_slug(cls) -> str

get_code_example <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L750" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_code_example(cls) -> Optional[str]

Returns the code example for the given block. Attempts to parse code example from the class docstring if an override is not provided.

get_description <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L727" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
get_description(cls) -> Optional[str]

Returns the description for the current block. Attempts to parse description from class docstring if an override is not defined.

is_block_class <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1438" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
is_block_class(block: Any) -> TypeGuard[type['Block']]

load <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1146" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load(cls, name: str, validate: bool = True, client: Optional['PrefectClient'] = None) -> 'Self'

Retrieves data from the block document with the given name for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

If a block document for a given block type is saved with a different schema than the current class calling load, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • name: The name or slug of the block document. A block document slug is a string with the format <block_type_slug>/<block_document_name>
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected.

Raises:

  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

Examples:

Load from a Block subclass with a block document name:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Custom.load("my-custom-message")

Load from Block with a block document slug:

python
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

loaded_block = Block.load("custom/my-custom-message")

Migrate a block document to a new schema:

python
# original class
class Custom(Block):
    message: str

Custom(message="Hello!").save("my-custom-message")

# Updated class with new required field
class Custom(Block):
    message: str
    number_of_ducks: int

loaded_block = Custom.load("my-custom-message", validate=False)

# Prints UserWarning about schema mismatch

loaded_block.number_of_ducks = 42

loaded_block.save("my-custom-message", overwrite=True)

load_from_ref <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1311" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
load_from_ref(cls, ref: Union[str, UUID, dict[str, Any]], validate: bool = True, client: 'PrefectClient | None' = None) -> Self

Retrieves data from the block document by given reference for the block type that corresponds with the current class and returns an instantiated version of the current class with the data stored in the block document.

This function will dispatch to aload_from_ref when called from an async context.

Provided reference can be a block document ID, or a reference data in dictionary format. Supported dictionary reference formats are:

  • {"block_document_id": <block_document_id>}
  • {"block_document_slug": <block_document_slug>}

If a block document for a given block type is saved with a different schema than the current class calling load_from_ref, a warning will be raised.

If the current class schema is a subset of the block document schema, the block can be loaded as normal using the default validate = True.

If the current class schema is a superset of the block document schema, load_from_ref must be called with validate set to False to prevent a validation error. In this case, the block attributes will default to None and must be set manually and saved to a new block document before the block can be used as expected.

Args:

  • ref: The reference to the block document. This can be a block document ID, or one of supported dictionary reference formats.
  • validate: If False, the block document will be loaded without Pydantic validating the block schema. This is useful if the block schema has changed client-side since the block document referred to by name was saved.
  • client: The client to use to load the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Raises:

  • ValueError: If invalid reference format is provided.
  • ValueError: If the requested block document is not found.

Returns:

  • An instance of the current class hydrated with the data stored in the
  • block document with the specified name.

logger <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L500" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
logger(self) -> LoggerOrAdapter

Returns a logger based on whether the SecretBlock is called from within a flow or task run context. If a run context is present, the logger property returns a run logger. Else, it returns a default logger labeled with the class's name.

Returns:

  • The run logger or a default logger with the class's name.

model_dump <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2063" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_dump(self) -> dict[str, Any]

model_json_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2005" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_json_schema(cls, by_alias: bool = True, ref_template: str = '#/definitions/{model}', schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema, mode: Literal['validation', 'serialization'] = 'validation') -> dict[str, Any]

TODO: stop overriding this method - use GenerateSchema in ConfigDict instead?

model_validate <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L2038" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
model_validate(cls: type[Self], obj: dict[str, Any] | Any) -> Self

read_secret <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L516" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
read_secret(self) -> bytes

Reads the configured secret from the secret storage service.

Returns:

  • The secret data.

register_type_and_schema <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1554" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
register_type_and_schema(cls, client: Optional['PrefectClient'] = None) -> None

Makes block available for configuration with current Prefect API. Recursively registers all nested blocks. Registration is idempotent.

This function will dispatch to aregister_type_and_schema when called from an async context.

Args:

  • client: Optional client to use for registering type and schema with the Prefect API. A new client will be created and used if one is not provided. This is ignored when called from a synchronous context.

save <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L1866" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
save(self, name: Optional[str] = None, overwrite: bool = False, client: Optional['PrefectClient'] = None) -> UUID

Saves the values of a block as a block document.

This function will dispatch to asave when called from an async context.

Args:

  • name: User specified name to give saved block document which can later be used to load the block document.
  • overwrite: Boolean value specifying if values should be overwritten if a block document with the specified name already exists.
  • client: The client to use to save the block document. If not provided, the default client will be injected. This is ignored when called from a synchronous context.

Returns:

  • The ID of the saved block document.

ser_model <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L424" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
ser_model(self, handler: SerializerFunctionWrapHandler, info: SerializationInfo) -> Any

validate_block_type_slug <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/core.py#L365" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
validate_block_type_slug(cls, values: Any) -> Any

Validates that the block_type_slug in the input values matches the expected block type slug for the class. This helps pydantic to correctly discriminate between different Block subclasses when validating Union types of Blocks.

write_secret <sup><a href="https://github.com/PrefectHQ/prefect/blob/main/src/prefect/blocks/abstract.py#L525" target="_blank"><Icon icon="github" style="width: 14px; height: 14px;" /></a></sup>

python
write_secret(self, secret_data: bytes) -> str

Writes secret data to the configured secret in the secret storage service.

Args:

  • secret_data: The secret data to write.

Returns:

  • The key of the secret that can be used for retrieval.