Skip to content

Commit fd73e49

Browse files
AmatyaAvadhanulakfarazcryptoe
authored
Fetch active tasks from memory in SeekableStreamSupervisor (#16098)
SeekableStreamSupervisor fetches the payloads of every active task in its datasource twice in every RunNotice. In large clusters, this may cause the RunNotice to take a long time to finish. This patch can help reduce the load on the DB significantly by fetching these payloads from memory. Co-authored-by: Kashif Faraz <kashif.faraz@gmail.com> Co-authored-by: cryptoe <karankumar1100@gmail.com>
1 parent 11eecb4 commit fd73e49

File tree

5 files changed

+214
-141
lines changed

5 files changed

+214
-141
lines changed

0 commit comments

Comments
 (0)