bang_nh

I encountered the same issue. We can ignore any data with None as below. ``` def _load_process(data_id): data = global_state.get_data(data_id) dtypes = global_state.get_dtypes(data_id) mdata = global_state.get_metadata(data_id) if data is None...

I'm having the same issue. Is there any way to solve the issue?

Thanks @gustavo-maxmilhas. I also need KubernetesJobOperator, so it seems more difficult to me.

> If you need to use xcom push, just make the init container yourself in the spark operator template (based on https://github.com/apache/airflow/blob/main/airflow/providers/cncf/kubernetes/utils/xcom_sidecar.py) > > ``` > volumes: > - name:...