tests.system.openlineage.operator¶
模块内容¶
类¶
此运算符为系统测试目的而添加。 |
函数¶
|
|
|
|
|
|
|
使用此 Jinja 方法访问名为 'var' 的环境变量。 |
|
|
|
|
|
|
|
检查结果是否“等于”期望值。 |
属性¶
- tests.system.openlineage.operator.env_var(var, default=None)[源代码]¶
使用此 Jinja 方法访问名为 'var' 的环境变量。
如果未设置此类环境变量，则返回默认值。如果默认值为 None，则会针对未定义的变量引发异常。
- tests.system.openlineage.operator.match(expected, result, env)[源代码]¶
检查结果是否“等于”期望值。
省略未在预期值中指定的键，并解析找到的任何 Jinja 模板。
- class tests.system.openlineage.operator.OpenLineageTestOperator(event_templates=None, file_path=None, env=setup_jinja(), allow_duplicate_events=False, clear_variables=True, **kwargs)[源代码]¶
基类:
airflow.models.operator.BaseOperator此运算符为系统测试目的而添加。
它将初始化时设置的预期事件模板与 OpenLineage 集成发出的并存储在 VariableTransport 的变量中的模板进行比较。 :param event_templates: 字典，其中键是 VariableTransport 使用的键，格式为 <DAG_ID>.<TASK_ID>.event.<EVENT_TYPE>，值是需要在接收到的事件中的事件模板（片段）。:param file_path: 或者，将使用指向包含事件模板的文件的 file_path :param env: 用于呈现事件模板的 Jinja 环境 :param allow_duplicate_events: 如果设置为 True，则允许同一键的多个事件 :param clear_variables: 如果设置为 True，则在检查事件后清除所有变量 :raises: 如果接收到的事件与预期事件不匹配，则抛出 ValueError。