Skip to main content
Version: Beta 🚧

SinkConfig

@sink_config (Decorator)​

Declare a SinkConfig which represents a post materialization hook that will be run after offline materialization.

Parameters

  • mode (str) - (Required) The compute mode for the transformation body

  • name (Optional[str]) - The name of the sink. defaults to name of function. Default: name of function

  • secrets (Optional[Dict[str,Union[Secret, str]]]) - A dictionary of Secret references that will be resolved and provided to the transformation function at runtime. During local development and testing, strings may be used instead Secret references. Default: None

Returns

An object of type SinkConfig

Example

from tecton import Embedding, batch_feature_view
from tecton.types import String
@sink_config(
mode = "pandas",
secrets = {"secret1": Secret(scope='prod', key='my_key')},
)
def sample_sink(df, context):
...

Was this page helpful?