d0982432e2
* fix(flows): fix relative imports cache invalidation Signed-off-by: pyranota <pyra@duck.com> * update flow_versions in the end Signed-off-by: pyranota <pyra@duck.com> * comms + fallback Signed-off-by: pyranota <pyra@duck.com> * add warn if fallback is used Signed-off-by: pyranota <pyra@duck.com> * include referenced scripts' hashes in flow_node id Signed-off-by: pyranota <pyra@duck.com> * improve fallback + TODOs Signed-off-by: pyranota <pyra@duck.com> * perf: optimize trigger Signed-off-by: pyranota <pyra@duck.com> * reduce TODOs Signed-off-by: pyranota <pyra@duck.com> * remove more TODOs Signed-off-by: pyranota <pyra@duck.com> * test thing Signed-off-by: pyranota <pyra@duck.com> * remove TODO Signed-off-by: pyranota <pyra@duck.com> * drop old flow trigger Signed-off-by: pyranota <pyra@duck.com> * add comments to migration Signed-off-by: pyranota <pyra@duck.com> --------- Signed-off-by: pyranota <pyra@duck.com>
9 lines
498 B
SQL
9 lines
498 B
SQL
-- Trigger cache invalidation whenever the .versions are updated in `flow`
|
|
-- This is ultimate way of instant cache invalidation. If the notification is being lost, lazy expiration timer will work as a fallback
|
|
CREATE TRIGGER flow_versions_append_trigger
|
|
AFTER UPDATE ON flow
|
|
FOR EACH ROW
|
|
-- Trigger only when versions are different
|
|
WHEN (NEW.versions[array_upper(NEW.versions,1)] IS DISTINCT FROM OLD.versions[array_upper(OLD.versions,1)])
|
|
EXECUTE FUNCTION notify_runnable_version_change('flow');
|