Os.path.dirname(os.path.realpath(\_file_)), 'your_yaml_file') Just simply create a params dictionary then pass to default_args: CONFIGFILE = os.path.join( So actually, you don't need XCOM to get the arguments. Not sure what you mean for 'dynamic', but when yaml file updated, if the reading file process is in dag file body, the dag will be refreshed to apply for the new args from yaml file.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |