@@ -1189,33 +1189,27 @@ def _collect_outputs(self):
1189
1189
)
1190
1190
return attr .evolve (output , ** output_wf )
1191
1191
1192
- def create_dotfile (self , type = "simple" , export = None , name = None , output_dir = None ):
1192
+ def create_dotfile (self , type = "simple" , export = None , name = None , output_dir = None ):
1193
1193
"""creating a graph - dotfile and optionally exporting to other formats"""
1194
1194
outdir = output_dir if output_dir is not None else self .cache_dir
1195
1195
if not name :
1196
1196
name = f"graph_{ self .name } "
1197
1197
if type == "simple" :
1198
1198
for task in self .graph .nodes :
1199
1199
self .create_connections (task )
1200
- dotfile = self .graph .create_dotfile_simple (
1201
- outdir = outdir , name = name
1202
- )
1200
+ dotfile = self .graph .create_dotfile_simple (outdir = outdir , name = name )
1203
1201
elif type == "nested" :
1204
1202
for task in self .graph .nodes :
1205
1203
self .create_connections (task )
1206
- dotfile = self .graph .create_dotfile_nested (
1207
- outdir = outdir , name = name
1208
- )
1204
+ dotfile = self .graph .create_dotfile_nested (outdir = outdir , name = name )
1209
1205
elif type == "detailed" :
1210
1206
# create connections with detailed=True
1211
1207
for task in self .graph .nodes :
1212
1208
self .create_connections (task , detailed = True )
1213
1209
# adding wf outputs
1214
1210
for (wf_out , lf ) in self ._connections :
1215
1211
self .graph .add_edges_description ((self .name , wf_out , lf .name , lf .field ))
1216
- dotfile = self .graph .create_dotfile_detailed (
1217
- outdir = outdir , name = name
1218
- )
1212
+ dotfile = self .graph .create_dotfile_detailed (outdir = outdir , name = name )
1219
1213
else :
1220
1214
raise Exception (
1221
1215
f"type of the graph can be simple, detailed or nested, "
0 commit comments