How can I set env variables like MALLOC_TRIM_THRESHOLD_ in DaskTaskRunner?

[avarma6]

Code looks like something like

@flow(task_runner=DaskTaskRunner())
def main():

Where in the code can I set the MALLOC_TRIM_THRESHOLD_ env var? The default is 65536 and I would like to change it to 0.

Thank you