wooden-dusk-90720
02/25/2023, 4:20 AMclass LinearFlow(FlowSpec):
@step
def start(self):
self.next(self.a)
@step
def a(self):
self.my_gigantic_var = 'xxx'
self.next(self.b)
@step
def b(self):
do_stuff(self.my_gigantic_var)
self.next(self.end)
@step
def end(self):
pass
Assuming step b
does not modify my_gigantic_var
, will my_gigantic_var
be serialized as an artifact again when step b
ends? As additional context, I noticed that my flow is getting OOM errors after do_stuff
has completed, which I'm guessing is due to serializing the artifacts