走讀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:

>>阅读原文<<