ephraimbuddy edited a comment on pull request #16823:
URL: https://github.com/apache/airflow/pull/16823#issuecomment-875098890
> > I want to be able to control the key used in pushing xcom when a value
is returned from a task
>
> Step back further 😁 Why? Please explain what you are trying to achieve,
not the implementation you have already thought about.
😀😀
Ok. For this case I described where I want to know in the UI if XCom was
uploaded to GCS and if not see the value, by customising the
`orm_deserialize_value`.
Take for instance, I'm building a custom xcom backend where I want to have
XComs stored in GCS if the value is large or store in db if the value is small.
And I want to know in the UI when I visit the XCom tab that this XCOM is in db
or in GCS.
Is there another way to accomplish this other than to prefix the keys for
xcoms stored in GCS with say `df' and do something like:
```
def orm_deserialize_value(self):
if self.key.starts_with('df'):
return 'Xcom uploaded to GCS'
return BaseXCom.deserialize_value(self)
```
I don't have a strong opinion on this feature though, we can close it if we
don't want it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
