如何解决如何在 k8podoperator 中使用函数调用 python 实用程序文件尝试但不起作用 p_utils.initiate_batch
p_utils = imp.load_source(u'p_utils',join('/efs/com/cm/utilities/cm_integration_python_utils.py'))
#######Python operator DAg code to run utility file with spaecific function within that python utility############
lash_site_init_task = Pythonoperator(task_id='xyz',python_callable=p_utils.initiate_batch,op_kwargs={'source':'lash','Feed':'site'},trigger_rule=TriggerRule.ALL_SUCCESS,dag=lash_dag)
-----------------------------------------------
######Convert pythonoperator using k8podopearator
lash_site_init_task = KubernetesPodoperator(namespace=namespace,image=image,cmds=["/bin/bash","-c",p_utils.compare_lst_modified_time],'Feed':'prvdr'},volume_mounts=[volume_mount],volumes=[volume],name="table-lash_prvdr_data_load_check",task_id='lash_prvdr_data_load_check',get_logs=True,provide_context=True,config_file=kube_config_path,in_cluster=False,cluster_context='aws',on_failure_callback=p_utils.update_audit_Failed_status('lash','prvdr','data_load_check'),dag=lash_dag)版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。