Hey everyone, I am trying to run an Flow compiled as an Airflow DAG, but I’m running into an error saying that my third-party libraries aren’t installed:

ModuleNotFoundError: No module named 'pandas'

. Do I need to use the

@conda

decorator in my flow steps to install the necessary libraries when running my Flow on Airflow? Thanks!

Correct. Or you can use an image that has

pandas

and specify it by using

@kubernetes(image='foo')

Ah got it! And do I need to ensure that my import statements are within the step function?

Correct

Sorry for the bother, but I have a follow-up question regarding the

@kubernetes

decorator. Is there a way to reference an image hosted in a private container registry, or would I have to manually alter the

KubernetesPodOperator

in the compiled airflow DAG as per these docs? Thanks!