File tree Expand file tree Collapse file tree 3 files changed +13
-2
lines changed Expand file tree Collapse file tree 3 files changed +13
-2
lines changed Original file line number Diff line number Diff line change @@ -68,6 +68,7 @@ class BaseChainingMixin:
68
68
69
69
def __init__ (self , * args , ** kwargs ):
70
70
super ().__init__ (* args , ** kwargs )
71
+ self .pipeline_called = False
71
72
self ._downstream_list : list [_Chainable ] = []
72
73
self ._upstream_list : list [_Chainable ] = []
73
74
Original file line number Diff line number Diff line change @@ -167,5 +167,5 @@ def run(
167
167
self ._execute ()
168
168
cache_called = self .cacher .cache_called
169
169
# TODO
170
- if not skip_plot and not cache_called :
170
+ if not skip_plot and not cache_called and not self . pipeline_called :
171
171
self .plot (show = False , save_path = True , dry_run = dry_run )
Original file line number Diff line number Diff line change @@ -65,7 +65,17 @@ def run(
65
65
print ("Running: " , node )
66
66
if hasattr (node , "cacher" ):
67
67
node .cacher .cache_policy = "OFF" if no_cache else "AUTO"
68
- node .run (dry_run = dry_run , save_path = working_directory , skip_plot = skip_plot )
68
+
69
+ # in case of error, add message
70
+ try :
71
+ node .pipeline_called = False
72
+ node .run (
73
+ dry_run = dry_run , save_path = working_directory , skip_plot = skip_plot
74
+ )
75
+ node .pipeline_called = True
76
+ except Exception as e :
77
+ raise Exception (f'Error while running the operator "{ node .tag } "' ) from e
78
+
69
79
if verbose :
70
80
print (f"Finished: { time .time () - stime :.03f} sec" )
71
81
if verbose :
You can’t perform that action at this time.
0 commit comments