tsdb=> CALL decompress_backfill(staging_table=>'temp', destination_hypertable=>'db');
ERROR:  permission denied for table bgw_job_stat
...
tsdb=> select remove_compression_policy('db');
 remove_compression_policy 
---------------------------
 t
(1 row)
tsdb=> CALL decompress_backfill(staging_table=>'temp', destination_hypertable=>'db');
NOTICE:  Decompressing chunk: _timescaledb_internal._hyper_5_16_chunk

CREATE OR REPLACE PROCEDURE decompress_backfill_wrapper(staging_table regclass,
    destination_hypertable regclass,
    on_conflict_action text DEFAULT 'NOTHING',
    delete_from_staging bool DEFAULT true,
    compression_job_push_interval interval DEFAULT '1 day',
    on_conflict_update_columns text[] DEFAULT '{}',
    skip_empty_ranges boolean DEFAULT false,
    on_conflict_target text DEFAULT '')
AS $proc$
DECLARE
    source text := staging_table::text;
    compress_after interval;

    dest_nspname name;
    dest_relname name;
BEGIN
    SELECT (get_schema_and_table_name(destination_hypertable)).* INTO STRICT dest_nspname, dest_relname;

    SELECT json_extract_path(config::json, 'compress_after')::text::interval INTO compress_after FROM timescaledb_information.jobs WHERE
        proc_name = 'policy_compression' AND
        hypertable_schema = dest_nspname AND
        hypertable_name  = dest_relname;

    PERFORM remove_compression_policy(destination_hypertable, if_exists => true);

    CALL decompress_backfill(staging_table, destination_hypertable, on_conflict_action, delete_from_staging,
    compression_job_push_interval, on_conflict_update_columns, skip_empty_ranges, on_conflict_target);

    IF compress_after IS NOT NULL THEN
        PERFORM add_compression_policy(destination_hypertable, compress_after);
    END IF;
END;

$proc$
LANGUAGE PLPGSQL;