коллеги, есть вопрос. Пытаюсь использовать xcom вместе с pythonOperator. Согласно документации, функцию для этого оператора нужно задавать так: def puller(**kwargs):
result = kwargs['ti'].xcom_pull(key='return_value', task_ids='abc'). Вопрос такой: если мне в эту функцию необходимо передать ещё какие-то параметры, то как правильно всё сделать? Если просто дописать параметр: def puller(parametr, **kwargs):... то даг сразу ломается, так как не получается вернуть значение kwargs['ti'].