\unset ECHO
\set QUIET 1
\pset format unaligned
\pset tuples_only true
\pset pager off
\set ON_ERROR_ROLLBACK 1
\set ON_ERROR_STOP true

SELECT quote_literal(CURRENT_TIMESTAMP) AS ct
\gset

INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a0 WHERE false', 'application_name=test');

INSERT INTO task (input, remote) VALUES ('SELECT 1/0 AS a1', 'application_name=test');

INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a2', 'application_name=test');
INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a3, 2 AS b3', 'application_name=test');
INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a4;SELECT 2 AS b4', 'application_name=test');
INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a5, 2 AS b5;SELECT 3 AS c5', 'application_name=test');
INSERT INTO task (input, remote) VALUES ('SELECT 1 AS a6, 2 AS b6;SELECT 3 AS c6, 4 AS d6', 'application_name=test');

WITH s AS (SELECT generate_series(1,10) AS s)  INSERT INTO task (input, max, live, remote) SELECT 'SELECT pg_sleep(0.1) AS a7', 2, '1 min', 'application_name=test' FROM s;

DO $body$ <<local>> DECLARE
    count bigint;
BEGIN
    WHILE true LOOP
        SELECT count(*) FROM task WHERE state NOT IN ('DONE', 'FAIL') INTO local.count;
        IF local.count = 0 THEN
            EXIT;
        END IF;
        PERFORM pg_sleep(0.1);
    END LOOP;
END;$body$ LANGUAGE plpgsql;

SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a0 WHERE false' AND start >= :ct::timestamp ORDER BY id desc;

SELECT input, output, state FROM task WHERE input = 'SELECT 1/0 AS a1' AND start >= :ct::timestamp ORDER BY id desc;

SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a2' AND start >= :ct::timestamp ORDER BY id desc;
SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a3, 2 AS b3' AND start >= :ct::timestamp ORDER BY id desc;
SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a4;SELECT 2 AS b4' AND start >= :ct::timestamp ORDER BY id desc;
SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a5, 2 AS b5;SELECT 3 AS c5' AND start >= :ct::timestamp ORDER BY id desc;
SELECT input, output, state FROM task WHERE input = 'SELECT 1 AS a6, 2 AS b6;SELECT 3 AS c6, 4 AS d6' AND start >= :ct::timestamp ORDER BY id desc;

SELECT input, output, state, count(id) FROM task WHERE input like 'SELECT pg_sleep(0.1) AS a7' AND start >= :ct::timestamp GROUP BY input, output, state, pid;