airflow.providers.cncf.kubernetes.python_kubernetes_script¶

用于使用 Kubernetes 装饰器的实用工具。

函数¶

`remove_task_decorator`(python_source, task_decorator_name)	移除 @task.kubernetes 或类似装饰器，以及 @setup 和 @teardown。
`write_python_script`(jinja_context, filename[, ...])	将 Python 脚本渲染到文件，以便在虚拟环境中执行。

模块内容¶

airflow.providers.cncf.kubernetes.python_kubernetes_script.remove_task_decorator(python_source, task_decorator_name)[source]¶

移除 @task.kubernetes 或类似装饰器，以及 @setup 和 @teardown。

参数:

python_source (str) – Python 源代码
task_decorator_name (str) – 任务装饰器名称

airflow.providers.cncf.kubernetes.python_kubernetes_script.write_python_script(jinja_context, filename, render_template_as_native_obj=False)[source]¶

将 Python 脚本渲染到文件，以便在虚拟环境中执行。

参数:

jinja_context (dict) – 要解包并在模板文件中用其占位符替换的 Jinja 上下文变量。
filename (str) – 要将渲染的脚本转储到的文件名。
render_template_as_native_obj (bool) – 如果为 True，渲染的 Jinja 模板将被转换为原生 Python 对象