@@ -1189,21 +1189,22 @@ 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 ):
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
+ outdir = output_dir if output_dir is not None else self .cache_dir
1194
1195
if not name :
1195
1196
name = f"graph_{ self .name } "
1196
1197
if type == "simple" :
1197
1198
for task in self .graph .nodes :
1198
1199
self .create_connections (task )
1199
1200
dotfile = self .graph .create_dotfile_simple (
1200
- outdir = self . output_dir , name = name
1201
+ outdir = outdir , name = name
1201
1202
)
1202
1203
elif type == "nested" :
1203
1204
for task in self .graph .nodes :
1204
1205
self .create_connections (task )
1205
1206
dotfile = self .graph .create_dotfile_nested (
1206
- outdir = self . output_dir , name = name
1207
+ outdir = outdir , name = name
1207
1208
)
1208
1209
elif type == "detailed" :
1209
1210
# create connections with detailed=True
@@ -1213,7 +1214,7 @@ def create_dotfile(self, type="simple", export=None, name=None):
1213
1214
for (wf_out , lf ) in self ._connections :
1214
1215
self .graph .add_edges_description ((self .name , wf_out , lf .name , lf .field ))
1215
1216
dotfile = self .graph .create_dotfile_detailed (
1216
- outdir = self . output_dir , name = name
1217
+ outdir = outdir , name = name
1217
1218
)
1218
1219
else :
1219
1220
raise Exception (
0 commit comments