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)[源代码]

删除 @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)[源代码]

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

参数
  • jinja_context (dict) – Jinja 上下文变量,用于解包并替换模板文件中的占位符。

  • filename (str) – 要将渲染后的脚本转储到的文件名。

  • render_template_as_native_obj (bool) – 如果为 True,则渲染的 Jinja 模板将转换为原生 Python 对象

此条目是否有帮助?