Just to elaborate - I one file is processed at 10AM with 1000 rows, I push rowcount=1000 to the pushgateway. Now the prometheus scrapes the gateway every 15s and keeps showing rowcount as 1000. Now if I get another file at 1030, and the file has 500 rows, the prometheus expects me to send 1500 (1000 + 500). This will allow me to keep track of total messages and use rate to find out how many new messages have come per minute, etc. But in dagster, I can't use this pattern - I have to send 500 (instead of 1000) as this is a new process and the previous counter object is closed. So what pattern can I use to keep track of total messages processed by a dagster pipeline over many runs?