From 93343270cbcba5472802bc1707f7f4c06dee82d3 Mon Sep 17 00:00:00 2001 From: Yevgeny Pats <16490766+yevgenypats@users.noreply.github.com> Date: Sun, 2 Jul 2023 09:58:59 +0300 Subject: [PATCH 1/2] fix: Add backend options to sync request --- plugin/v3/plugin.proto | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/plugin/v3/plugin.proto b/plugin/v3/plugin.proto index 070a7cc..24968db 100644 --- a/plugin/v3/plugin.proto +++ b/plugin/v3/plugin.proto @@ -67,11 +67,18 @@ message Sync { // marshalled arrow.Schema bytes table = 1; } + message BackendOptions { + // table name to use for state backend + string table_name = 1; + // connection path to use for state backend + string path = 2; + } message Request { repeated string tables = 1; repeated string skip_tables = 2; bool skip_dependent_tables = 3; bool deterministic_cq_id = 4; + BackendOptions backend = 5; } message Response { oneof message { From a0c75a1aa7fa643cf22dd9c5e1a9636e2c9c1c8d Mon Sep 17 00:00:00 2001 From: Herman Schaaf Date: Mon, 3 Jul 2023 09:48:39 +0100 Subject: [PATCH 2/2] Update plugin/v3/plugin.proto --- plugin/v3/plugin.proto | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/plugin/v3/plugin.proto b/plugin/v3/plugin.proto index 24968db..0348a2b 100644 --- a/plugin/v3/plugin.proto +++ b/plugin/v3/plugin.proto @@ -71,7 +71,7 @@ message Sync { // table name to use for state backend string table_name = 1; // connection path to use for state backend - string path = 2; + string connection = 2; } message Request { repeated string tables = 1;