openclimatefix / ocf-infrastructure

Infrastructure code for OCF's cloud environments
3 stars 6 forks source link

Update database once Consumer is done #299

Closed peterdudfield closed 2 months ago

peterdudfield commented 1 year ago

Detailed Description

How to update the input_data_last_updated once a consumer has run.

Context

Possible Implementation

peterdudfield commented 1 year ago

One to think about @devsjc

devsjc commented 1 year ago

I feel like this is one for the dag not the consumer - especially if all the various data import jobs are meant to update the table, one could envisage a task at the end of each relevant dag

peterdudfield commented 1 year ago

yea, I'll try and write something and see how neat it looks in the dag

devsjc commented 1 year ago

Seems like less code duplication and seperation that way as well - one reuseable task vs several individual implementations in seperate microservices.

peterdudfield commented 2 months ago

Ill close this for now, as we do update this through the API now