走读airflow学到的东东

自动发掘dag实例 import imp def process_file(self, filepath): mod_name, file_ext = os.path.splitext(os.path.split(filepath)[-1]) if file_ext != '.py': return try:

>>阅读原文<<