self.operator = KubernetesPodOperator(
namespace=self.namespace, image=self.image, name=self.name,
cmds=self.cmds,
arguments=self.arguments,
startup_timeout_seconds=600,
is_delete_operator_pod=True,
# the operator could run successfully but the directory /tmp is not mounted to kubernetes operator
volumes=[self.volume],
volume_mounts=[self.volume_mount],
**self.context)
文档中的示例与您的代码非常相似,只是参数是复数
volume_mounts
和volumes
。对于您的代码,它将如下所示:相关问题 更多 >
编程相关推荐