Run an MPI program that uses NumPy arrays in distributed operations like gather, scatter, and a custom all reduce. python flow.py --environment=conda run