@@ -75,9 +75,10 @@ def update_nodes(item, appwrapper_name, cpu, memory, gpu, workers):
7575 update_affinity (spec , appwrapper_name )
7676 update_resources (spec , cpu , memory , gpu )
7777
78- def write_user_appwrapper (user_yaml , appwrapper_name ):
79- with open (f' { appwrapper_name } .yaml' ,'w' ) as outfile :
78+ def write_user_appwrapper (user_yaml , output_file_name ):
79+ with open (output_file_name ,'w' ) as outfile :
8080 yaml .dump (user_yaml , outfile , default_flow_style = False )
81+ print (f"Written to: { output_file_name } " )
8182
8283def generate_appwrapper (cpu , memory , gpu , workers , template ):
8384 user_yaml = read_template (template )
@@ -87,7 +88,10 @@ def generate_appwrapper(cpu, memory, gpu, workers, template):
8788 update_names (user_yaml , item , appwrapper_name , cluster_name )
8889 update_custompodresources (item , cpu , memory , gpu , workers )
8990 update_nodes (item , appwrapper_name , cpu , memory , gpu , workers )
90- write_user_appwrapper (user_yaml , appwrapper_name )
91+ outfile = appwrapper_name + ".yaml"
92+ write_user_appwrapper (user_yaml , outfile )
93+ return outfile
94+
9195
9296def main ():
9397 parser = argparse .ArgumentParser (description = 'Generate user AppWrapper' )
@@ -104,7 +108,8 @@ def main():
104108 workers = args .workers
105109 template = args .template
106110
107- generate_appwrapper (cpu , memory , gpu , workers , template )
111+ outfile = generate_appwrapper (cpu , memory , gpu , workers , template )
112+ return outfile
108113
109114if __name__ == "__main__" :
110115 main ()
0 commit comments