@@ -564,7 +564,7 @@ def export(self, prefix="output", format="python"):
564
564
wfdef = '%s = Workflow("%s")' % (self .name , self .name )
565
565
lines .append (wfdef )
566
566
for idx , node in enumerate (nodes ):
567
- nodename = node .fullname ('.' , '_' )
567
+ nodename = node .fullname . replace ('.' , '_' )
568
568
# write nodes
569
569
nodelines = format_node (node , format = 'python' )
570
570
for line in nodelines :
@@ -587,12 +587,12 @@ def export(self, prefix="output", format="python"):
587
587
functions [args [1 ]] = funcname
588
588
args [1 ] = funcname
589
589
args = tuple ([arg for arg in args if arg ])
590
- line = connect_template % (u .name , args ,
590
+ line = connect_template % (u .fullname . replace ( '.' , '_' ) , args ,
591
591
nodename , cd [1 ])
592
592
line = line .replace ("'%s'" % funcname , funcname )
593
593
lines .append (line )
594
594
else :
595
- lines .append (connect_template2 % (u .name , cd [0 ],
595
+ lines .append (connect_template2 % (u .fullname . replace ( '.' , '_' ) , cd [0 ],
596
596
nodename , cd [1 ]))
597
597
functionlines = ['# Functions' ]
598
598
for function in functions :
0 commit comments