mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-07-04 13:00:38 +00:00
4071cb56ae
* feat(flow): stabilize eval interval scheduling * fix(flow): satisfy eval schedule clippy * test(flow): trim eval schedule coverage * test(flow): cover stable eval scheduling * fix(flow): reserve scheduled runtime hint * test(flow): trim sqlness result eof * fix(flow): harden eval schedule edges * fix(flow): address scheduled flow review * fix(flow): clean scheduled config handling * test(flow): add eval interval compat case * test(flow): cover show create flow in compat * fix(flow): drop scheduled time from flow context * test(flow): assert scheduled now binding --------- Signed-off-by: discord9 <discord9@163.com> Signed-off-by: evenyag <realevenyag@gmail.com> Co-authored-by: discord9 <discord9@163.com>
34 lines
1.0 KiB
SQL
34 lines
1.0 KiB
SQL
SELECT flow_name, source_table_names
|
|
FROM information_schema.flows
|
|
WHERE flow_name IN ('compat_sql_eval_flow', 'compat_tql_eval_flow')
|
|
ORDER BY flow_name;
|
|
|
|
SHOW CREATE FLOW compat_sql_eval_flow;
|
|
|
|
SHOW CREATE FLOW compat_tql_eval_flow;
|
|
|
|
SHOW CREATE TABLE compat_sql_eval_sink;
|
|
|
|
SHOW CREATE TABLE compat_tql_eval_sink;
|
|
|
|
INSERT INTO compat_sql_input VALUES
|
|
('2026-06-25 00:00:00', 'a', 1.0),
|
|
('2026-06-25 00:00:01', 'b', 2.0);
|
|
|
|
INSERT INTO compat_tql_input VALUES
|
|
(now() - '17s'::interval, 'host1', 'idc1', 200),
|
|
(now() - '13s'::interval, 'host2', 'idc1', 401),
|
|
(now() - '7s'::interval, 'host3', 'idc2', 500);
|
|
|
|
-- SQLNESS REPLACE (ADMIN\sFLUSH_FLOW\('\w+'\)\s+\|\n\+-+\+\n\|\s+)[0-9]+\s+\| $1 FLOW_FLUSHED |
|
|
ADMIN FLUSH_FLOW('compat_sql_eval_flow');
|
|
|
|
-- SQLNESS REPLACE (ADMIN\sFLUSH_FLOW\('\w+'\)\s+\|\n\+-+\+\n\|\s+)[0-9]+\s+\| $1 FLOW_FLUSHED |
|
|
ADMIN FLUSH_FLOW('compat_tql_eval_flow');
|
|
|
|
SELECT count(*) > 0 AS sql_flow_executed
|
|
FROM compat_sql_eval_sink;
|
|
|
|
SELECT count(*) > 0 AS tql_flow_executed
|
|
FROM compat_tql_eval_sink;
|