https://dagster.io/ logo
Title
m

Mikhail Knyazev

11/02/2022, 9:41 AM
Does anyone else experience the problem with “live” event logs? The problem is I stopped receiving the live updates from pipelines, and only see changes after page refresh. Websocket connection is normal, but I don’t see any messages flowing. I use Dagit 1.0.15 behind Nginx, will try to downgrade and check again.
Can confirm downgrading to 1.0.14 solved the issue - I can see live log updates and the flow of messages in the WS
a

Adam Bloom

11/02/2022, 1:42 PM
I’ve seen this behave intermittently like you described, across numerous dagster versions
a

alex

11/02/2022, 3:41 PM
which database are you using? there is a “disable websockets” toggle in the settings page that can be used to force polling
m

Mikhail Knyazev

11/02/2022, 3:42 PM
which database are you using?
postgresql in docker
a

alex

11/02/2022, 3:45 PM
you see any error logs for the dagit process?
m

Mikhail Knyazev

11/02/2022, 3:48 PM
I rebuilt the image with dagster==1.0.15 and it works now 🤔
a

alex

11/02/2022, 3:53 PM
there was a recent change https://github.com/dagster-io/dagster/commit/e8d8525bfd01d9f283148a0da3bd3b25271a16b2 so one possibility is that certain
sqlalchemy
versions have problems? unclear it could also be this sporadic issue that Adam mentions which im not sure what to make of . One speculation is that its related to our old implementation stuck on an ancient version of
rx
which i am hoping to update to async generator backed https://github.com/dagster-io/dagster/pull/9334?no-redirect=1
a

Adam Bloom

11/02/2022, 4:17 PM
@alex I was hoping that change would help with the "Unexpected GraphQL Error"s (postgres), but no luck. still getting sqlalchemy
(psycopg2.OperationalError) SSL SYSCALL error: EOF detected
pretty much daily
a

alex

11/02/2022, 4:26 PM
hmm, do you have
keepalive
related kwargs set in addition to enabling ssl?
a

Adam Bloom

11/02/2022, 4:28 PM
yup, we added that months ago, but no luck. Seems to only happen when dagit has been idle for a while (i.e. first use of the day). Pretty sure the database has long closed connections as idle that sqlalchemy is attempting to use.
a

alex

11/02/2022, 4:34 PM
looks like we already have
pool_recycle
on for mysql dagit connection - could add it to pg storages
a

Adam Bloom

11/02/2022, 4:48 PM
sqlalchemy docs explicitly mention mysql and not postgres for that param, but also sounds like it would do what we want? https://docs.sqlalchemy.org/en/14/core/pooling.html#setting-pool-recycle
@alex were you going to add that? or open to a PR to do so?
a

alex

11/03/2022, 7:53 PM
you down to submit one?
a

Adam Bloom

11/03/2022, 7:53 PM
I can definitely do that
:thank-you-box: 1
@alex good to always be enabled? or think this should be configurable?
a

alex

11/03/2022, 7:58 PM
one argument is that since the mysql variant is always set it should be fine in PG as well- changing out connections once an hour seems pretty reasonable making a
dagit
cli flag to set it is probably ideal but a lot more plumbing. If we did that i think we would still have the default be the same
3600
s in both
a

Adam Bloom

11/07/2022, 5:00 PM
@alex wasn't too much plumbing! https://github.com/dagster-io/dagster/pull/10416
:nice: 1