From 3d735ec69dd7bf94592d1b58b84862fb218f66c3 Mon Sep 17 00:00:00 2001 From: BohuTANG Date: Mon, 22 Jan 2024 19:43:20 +0800 Subject: [PATCH] chore: remove obsolete configs --- src/query/config/src/config.rs | 70 --- src/query/config/src/obsolete.rs | 139 +----- tests/cloud_control_server/simple_server.py | 5 +- tests/cloud_control_server/task_pb2.py | 125 ++--- tests/cloud_control_server/task_pb2_grpc.py | 527 ++++++++++++-------- 5 files changed, 393 insertions(+), 473 deletions(-) diff --git a/src/query/config/src/config.rs b/src/query/config/src/config.rs index 32c51d8d779be..b228bba1c9cfe 100644 --- a/src/query/config/src/config.rs +++ b/src/query/config/src/config.rs @@ -1486,58 +1486,6 @@ pub struct QueryConfig { #[clap(long, value_name = "VALUE", default_value = "90")] pub(crate) data_retention_time_in_days_max: u64, - // ----- the following options/args are all deprecated ---- - // ----- and turned into Option, to help user migrate the configs ---- - /// OBSOLETED: Table disk cache size (mb). - #[clap(long, value_name = "VALUE")] - pub table_disk_cache_mb_size: Option, - - /// OBSOLETED: Table Meta Cached enabled - #[clap(long, value_name = "VALUE")] - pub table_meta_cache_enabled: Option, - - /// OBSOLETED: Max number of cached table block meta - #[clap(long, value_name = "VALUE")] - pub table_cache_block_meta_count: Option, - - /// OBSOLETED: Table memory cache size (mb) - #[clap(long, value_name = "VALUE")] - pub table_memory_cache_mb_size: Option, - - /// OBSOLETED: Table disk cache folder root - #[clap(long, value_name = "VALUE")] - pub table_disk_cache_root: Option, - - /// OBSOLETED: Max number of cached table snapshot - #[clap(long, value_name = "VALUE")] - pub table_cache_snapshot_count: Option, - - /// OBSOLETED: Max number of cached table snapshot statistics - #[clap(long, value_name = "VALUE")] - pub table_cache_statistic_count: Option, - - /// OBSOLETED: Max number of cached table segment - #[clap(long, value_name = "VALUE")] - pub table_cache_segment_count: Option, - - /// OBSOLETED: Max number of cached bloom index meta objects - #[clap(long, value_name = "VALUE")] - pub table_cache_bloom_index_meta_count: Option, - - /// OBSOLETED: - /// Max number of cached bloom index filters, default value is 1024 * 1024 items. - /// One bloom index filter per column of data block being indexed will be generated if necessary. - /// - /// For example, a table of 1024 columns, with 800 data blocks, a query that triggers a full - /// table filter on 2 columns, might populate 2 * 800 bloom index filter cache items (at most) - #[clap(long, value_name = "VALUE")] - pub table_cache_bloom_index_filter_count: Option, - - /// OBSOLETED: (cache of raw bloom filter data is no longer supported) - /// Max bytes of cached bloom filter bytes. - #[clap(long, value_name = "VALUE")] - pub(crate) table_cache_bloom_index_data_bytes: Option, - /// Disable some system load(For example system.configs) for cloud security. #[clap(long, value_name = "VALUE")] pub disable_system_table_load: bool, @@ -1728,18 +1676,6 @@ impl From for QueryConfig { internal_merge_on_read_mutation: false, data_retention_time_in_days_max: 90, - // obsoleted config entries - table_disk_cache_mb_size: None, - table_meta_cache_enabled: None, - table_cache_block_meta_count: None, - table_memory_cache_mb_size: None, - table_disk_cache_root: None, - table_cache_snapshot_count: None, - table_cache_statistic_count: None, - table_cache_segment_count: None, - table_cache_bloom_index_meta_count: None, - table_cache_bloom_index_filter_count: None, - table_cache_bloom_index_data_bytes: None, // disable_system_table_load: inner.disable_system_table_load, openai_api_chat_base_url: inner.openai_api_chat_base_url, @@ -2679,11 +2615,6 @@ pub struct CacheConfig { default_value = "0" )] pub table_data_deserialized_data_bytes: u64, - - // ----- the following options/args are all deprecated ---- - /// Max number of cached table segment - #[clap(long = "cache-table-meta-segment-count", value_name = "VALUE")] - pub table_meta_segment_count: Option, } impl Default for CacheConfig { @@ -2832,7 +2763,6 @@ mod cache_config_converters { .table_data_cache_population_queue_size, disk_cache_config: value.disk_cache_config.into(), table_data_deserialized_data_bytes: value.table_data_deserialized_data_bytes, - table_meta_segment_count: None, } } } diff --git a/src/query/config/src/obsolete.rs b/src/query/config/src/obsolete.rs index a65747e004385..904631956a436 100644 --- a/src/query/config/src/obsolete.rs +++ b/src/query/config/src/obsolete.rs @@ -22,145 +22,22 @@ use crate::Config; // The following code should be removed from the release after the next release. // Just give user errors without any detail explanation and migration suggestions. impl Config { - pub const fn obsoleted_option_keys() -> &'static [&'static str; 11] { - &[ - "table_disk_cache_mb_size", - "table_meta_cache_enabled", - "table_cache_block_meta_count", - "table_memory_cache_mb_size", - "table_disk_cache_root", - "table_cache_snapshot_count", - "table_cache_statistic_count", - "table_cache_segment_count", - "table_cache_bloom_index_meta_count", - "table_cache_bloom_index_filter_count", - "table_cache_bloom_index_data_bytes", - ] + pub const fn obsoleted_option_keys() -> &'static [&'static str; 1] { + &["obsoleted-name"] } pub(crate) fn check_obsoleted(&self) -> Result<()> { let check_results = vec![ + // This is a demo. Self::check( - &self.query.table_disk_cache_mb_size, - "table-disk-cache-mb-size", - "cache-disk-max-bytes", + &Some("obsoleted-name"), + "obsoleted-name", + "new-name", r#" - [cache] - ... - data_cache_storage = "disk" - ... - [cache.disk] - max_bytes = [MAX_BYTES] ... + name-name = "value" "#, - "CACHE_DISK_MAX_BYTES", - ), - Self::check( - &self.query.table_meta_cache_enabled, - "table-meta-cache-enabled", - "cache-enable-table-meta-cache", - r#" - [cache] - enable_table_meta_cache=[true|false] - "#, - "CACHE_ENABLE_TABLE_META_CACHE", - ), - Self::check( - &self.query.table_cache_block_meta_count, - "table-cache-block-meta-count", - "N/A", - "N/A", - "N/A", - ), - Self::check( - &self.query.table_memory_cache_mb_size, - "table-memory-cache-mb-size", - "N/A", - "N/A", - "N/A", - ), - Self::check( - &self.query.table_disk_cache_root, - "table-disk-cache-root", - "cache-disk-path", - r#" - [cache] - ... - data_cache_storage = "disk" - ... - [cache.disk] - max_bytes = [MAX_BYTES] - path = [PATH] - ... - "#, - "CACHE_DISK_PATH", - ), - Self::check( - &self.query.table_cache_snapshot_count, - "table-cache-snapshot-count", - "cache-table-meta-snapshot-count", - r#" - [cache] - table_meta_snapshot_count = [COUNT] - "#, - "CACHE_TABLE_META_SNAPSHOT_COUNT", - ), - Self::check( - &self.query.table_cache_statistic_count, - "table-cache-statistic-count", - "cache-table-meta-statistic-count", - r#" - [cache] - table_meta_statistic_count = [COUNT] - "#, - "CACHE_TABLE_META_STATISTIC_COUNT", - ), - Self::check( - &self.query.table_cache_segment_count, - "table-cache-segment-count", - "cache-table-meta-segment-count", - r#" - [cache] - table_meta_segment_count = [COUNT] - "#, - "CACHE_TABLE_META_SEGMENT_COUNT", - ), - Self::check( - &self.query.table_cache_bloom_index_meta_count, - "table-cache-bloom-index-meta-count", - "cache-table-bloom-index-meta-count", - r#" - [cache] - table_bloom_index_meta_count = [COUNT] - "#, - "CACHE_TABLE_BLOOM_INDEX_META_COUNT", - ), - Self::check( - &self.query.table_cache_bloom_index_filter_count, - "table-cache-bloom-index-filter-count", - "cache-table-bloom-index-filter-count", - r#" - [cache] - table_bloom_index_filter_count = [COUNT] - "#, - "CACHE_TABLE_BLOOM_INDEX_FILTER_COUNT", - ), - Self::check( - &self.query.table_cache_bloom_index_data_bytes, - "table-cache-bloom-index-data-bytes", - "N/A", - "N/A", - "N/A", - ), - Self::check( - &self.cache.table_meta_segment_count, - "cache-table-meta-segment-count", - "cache-table-meta-segment-bytes", - r#" - [cache] - table_meta_segment_bytes = [BYTES] - "#, - "CACHE_TABLE_META_SEGMENT_BYTES", + "NEW-NAME", ), ]; diff --git a/tests/cloud_control_server/simple_server.py b/tests/cloud_control_server/simple_server.py index 2fd225eff44f1..adb16b3b1cad6 100644 --- a/tests/cloud_control_server/simple_server.py +++ b/tests/cloud_control_server/simple_server.py @@ -265,14 +265,17 @@ def GetTaskDependents(self, request, context): root = TASK_DB[root.after[0]] l.insert(0, root) return task_pb2.GetTaskDependentsResponse(task=l) + def EnableTaskDependents(self, request, context): print("EnableTaskDependents", request) task_name = request.task_name if task_name not in TASK_DB: - return task_pb2.EnableTaskDependentsResponse() + return task_pb2.EnableTaskDependentsResponse() task = TASK_DB[task_name] task.status = task_pb2.Task.Started return task_pb2.EnableTaskDependentsResponse() + + def serve(): server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) task_pb2_grpc.add_TaskServiceServicer_to_server(TaskService(), server) diff --git a/tests/cloud_control_server/task_pb2.py b/tests/cloud_control_server/task_pb2.py index 3b3ad6c56c62e..80f53e684b0d0 100644 --- a/tests/cloud_control_server/task_pb2.py +++ b/tests/cloud_control_server/task_pb2.py @@ -6,75 +6,76 @@ from google.protobuf import descriptor_pool as _descriptor_pool from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder + # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() - - -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\ntask.proto\x12\ttaskproto\"\xe9\x01\n\x0fScheduleOptions\x12\x15\n\x08interval\x18\x01 \x01(\x05H\x00\x88\x01\x01\x12\x11\n\x04\x63ron\x18\x02 \x01(\tH\x01\x88\x01\x01\x12\x16\n\ttime_zone\x18\x03 \x01(\tH\x02\x88\x01\x01\x12>\n\rschedule_type\x18\x04 \x01(\x0e\x32\'.taskproto.ScheduleOptions.ScheduleType\"0\n\x0cScheduleType\x12\x11\n\rinterval_type\x10\x00\x12\r\n\tcron_type\x10\x01\x42\x0b\n\t_intervalB\x07\n\x05_cronB\x0c\n\n_time_zone\"t\n\x10WarehouseOptions\x12\x16\n\twarehouse\x18\x01 \x01(\tH\x00\x88\x01\x01\x12!\n\x14using_warehouse_size\x18\x02 \x01(\tH\x01\x88\x01\x01\x42\x0c\n\n_warehouseB\x17\n\x15_using_warehouse_size\"\x93\x03\n\x11\x43reateTaskRequest\x12\x11\n\ttask_name\x18\x01 \x01(\t\x12\x11\n\ttenant_id\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x03 \x01(\t\x12\r\n\x05owner\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x36\n\x11warehouse_options\x18\x08 \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12,\n\x1fsuspend_task_after_num_failures\x18\t \x01(\x05H\x01\x88\x01\x01\x12\x14\n\x0cif_not_exist\x18\n \x01(\x08\x12\r\n\x05\x61\x66ter\x18\x0b \x03(\t\x12\x1b\n\x0ewhen_condition\x18\x0c \x01(\tH\x02\x88\x01\x01\x42\n\n\x08_commentB\"\n _suspend_task_after_num_failuresB\x11\n\x0f_when_condition\"8\n\tTaskError\x12\x0c\n\x04kind\x18\x01 \x01(\t\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x0c\n\x04\x63ode\x18\x03 \x01(\x05\"Y\n\x12\x43reateTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x12\x0f\n\x07task_id\x18\x02 \x01(\x04\x42\x08\n\x06_error\"I\n\x0f\x44ropTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x10\n\x08if_exist\x18\x03 \x01(\x08\"F\n\x10\x44ropTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\":\n\x12\x45xecuteTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\"I\n\x13\x45xecuteTaskResponse\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\"M\n\x13\x44\x65scribeTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x10\n\x08if_exist\x18\x03 \x01(\x08\"\xd0\x04\n\x04Task\x12\x0f\n\x07task_id\x18\x01 \x01(\x04\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x36\n\x11warehouse_options\x18\x08 \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12\x1e\n\x11next_scheduled_at\x18\t \x01(\tH\x01\x88\x01\x01\x12,\n\x1fsuspend_task_after_num_failures\x18\n \x01(\x05H\x02\x88\x01\x01\x12&\n\x06status\x18\x0c \x01(\x0e\x32\x16.taskproto.Task.Status\x12\x12\n\ncreated_at\x18\x0e \x01(\t\x12\x12\n\nupdated_at\x18\x0f \x01(\t\x12\x1e\n\x11last_suspended_at\x18\x10 \x01(\tH\x03\x88\x01\x01\x12\r\n\x05\x61\x66ter\x18\x11 \x03(\t\x12\x1b\n\x0ewhen_condition\x18\x12 \x01(\tH\x04\x88\x01\x01\"$\n\x06Status\x12\r\n\tSuspended\x10\x00\x12\x0b\n\x07Started\x10\x01\x42\n\n\x08_commentB\x14\n\x12_next_scheduled_atB\"\n _suspend_task_after_num_failuresB\x14\n\x12_last_suspended_atB\x11\n\x0f_when_condition\"i\n\x14\x44\x65scribeTaskResponse\x12\x1d\n\x04task\x18\x01 \x01(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\"p\n\x10ShowTasksRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\tname_like\x18\x02 \x01(\t\x12\x14\n\x0cresult_limit\x18\x04 \x01(\x05\x12\x0e\n\x06owners\x18\x05 \x03(\t\x12\x10\n\x08task_ids\x18\x06 \x03(\t\"g\n\x11ShowTasksResponse\x12\x1e\n\x05tasks\x18\x01 \x03(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\"\xf0\x04\n\x10\x41lterTaskRequest\x12\x11\n\ttask_name\x18\x01 \x01(\t\x12\x11\n\ttenant_id\x18\x02 \x01(\t\x12\x17\n\nquery_text\x18\x03 \x01(\tH\x00\x88\x01\x01\x12\x14\n\x07\x63omment\x18\x04 \x01(\tH\x01\x88\x01\x01\x12\x42\n\x0f\x61lter_task_type\x18\x05 \x01(\x0e\x32).taskproto.AlterTaskRequest.AlterTaskType\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x10\n\x08if_exist\x18\x08 \x01(\x08\x12\x36\n\x11warehouse_options\x18\t \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12,\n\x1fsuspend_task_after_num_failures\x18\n \x01(\x05H\x02\x88\x01\x01\x12\x1b\n\x0ewhen_condition\x18\x0b \x01(\tH\x03\x88\x01\x01\x12\x11\n\tadd_after\x18\x0c \x03(\t\x12\x14\n\x0cremove_after\x18\r \x03(\t\"n\n\rAlterTaskType\x12\x0b\n\x07Suspend\x10\x00\x12\n\n\x06Resume\x10\x01\x12\x07\n\x03Set\x10\x02\x12\x0c\n\x08ModifyAs\x10\x03\x12\x0e\n\nModifyWhen\x10\x04\x12\x0c\n\x08\x41\x64\x64\x41\x66ter\x10\x05\x12\x0f\n\x0bRemoveAfter\x10\x06\x42\r\n\x0b_query_textB\n\n\x08_commentB\"\n _suspend_task_after_num_failuresB\x11\n\x0f_when_condition\"f\n\x11\x41lterTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x12\x1d\n\x04task\x18\x02 \x01(\x0b\x32\x0f.taskproto.TaskB\x08\n\x06_error\"\xc1\x01\n\x13ShowTaskRunsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x1c\n\x14scheduled_time_start\x18\x02 \x01(\t\x12\x1a\n\x12scheduled_time_end\x18\x03 \x01(\t\x12\x14\n\x0cresult_limit\x18\x04 \x01(\x05\x12\x12\n\nerror_only\x18\x05 \x01(\x08\x12\x0e\n\x06owners\x18\x06 \x03(\t\x12\x10\n\x08task_ids\x18\x07 \x03(\t\x12\x11\n\ttask_name\x18\x08 \x01(\t\"\xcc\x04\n\x07TaskRun\x12\x0f\n\x07task_id\x18\x01 \x01(\x04\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x0e\n\x06run_id\x18\x08 \x01(\t\x12\x16\n\x0e\x61ttempt_number\x18\t \x01(\x05\x12\x36\n\x11warehouse_options\x18\n \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12\'\n\x05state\x18\x0b \x01(\x0e\x32\x18.taskproto.TaskRun.State\x12\x12\n\nerror_code\x18\x0c \x01(\x03\x12\x1a\n\rerror_message\x18\r \x01(\tH\x01\x88\x01\x01\x12\x16\n\x0escheduled_time\x18\x0e \x01(\t\x12\x1b\n\x0e\x63ompleted_time\x18\x10 \x01(\tH\x02\x88\x01\x01\x12\x10\n\x08query_id\x18\x11 \x01(\t\x12\x16\n\x0e\x63ondition_text\x18\x12 \x01(\t\x12\x14\n\x0croot_task_id\x18\x13 \x01(\t\"O\n\x05State\x12\r\n\tSCHEDULED\x10\x00\x12\r\n\tEXECUTING\x10\x01\x12\r\n\tSUCCEEDED\x10\x02\x12\n\n\x06\x46\x41ILED\x10\x03\x12\r\n\tCANCELLED\x10\x04\x42\n\n\x08_commentB\x10\n\x0e_error_messageB\x11\n\x0f_completed_time\"q\n\x14ShowTaskRunsResponse\x12%\n\ttask_runs\x18\x01 \x03(\x0b\x32\x12.taskproto.TaskRun\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\"S\n\x18GetTaskDependentsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x11\n\trecursive\x18\x03 \x01(\x08\"n\n\x19GetTaskDependentsResponse\x12\x1d\n\x04task\x18\x01 \x03(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error\"C\n\x1b\x45nableTaskDependentsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\"R\n\x1c\x45nableTaskDependentsResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error2\xe6\x05\n\x0bTaskService\x12I\n\nCreateTask\x12\x1c.taskproto.CreateTaskRequest\x1a\x1d.taskproto.CreateTaskResponse\x12O\n\x0c\x44\x65scribeTask\x12\x1e.taskproto.DescribeTaskRequest\x1a\x1f.taskproto.DescribeTaskResponse\x12L\n\x0b\x45xecuteTask\x12\x1d.taskproto.ExecuteTaskRequest\x1a\x1e.taskproto.ExecuteTaskResponse\x12\x43\n\x08\x44ropTask\x12\x1a.taskproto.DropTaskRequest\x1a\x1b.taskproto.DropTaskResponse\x12\x46\n\tAlterTask\x12\x1b.taskproto.AlterTaskRequest\x1a\x1c.taskproto.AlterTaskResponse\x12\x46\n\tShowTasks\x12\x1b.taskproto.ShowTasksRequest\x1a\x1c.taskproto.ShowTasksResponse\x12O\n\x0cShowTaskRuns\x12\x1e.taskproto.ShowTaskRunsRequest\x1a\x1f.taskproto.ShowTaskRunsResponse\x12^\n\x11GetTaskDependents\x12#.taskproto.GetTaskDependentsRequest\x1a$.taskproto.GetTaskDependentsResponse\x12g\n\x14\x45nableTaskDependents\x12&.taskproto.EnableTaskDependentsRequest\x1a\'.taskproto.EnableTaskDependentsResponseB!Z\x1f\x64\x61tabend.com/cloudcontrol/protob\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile( + b'\n\ntask.proto\x12\ttaskproto"\xe9\x01\n\x0fScheduleOptions\x12\x15\n\x08interval\x18\x01 \x01(\x05H\x00\x88\x01\x01\x12\x11\n\x04\x63ron\x18\x02 \x01(\tH\x01\x88\x01\x01\x12\x16\n\ttime_zone\x18\x03 \x01(\tH\x02\x88\x01\x01\x12>\n\rschedule_type\x18\x04 \x01(\x0e\x32\'.taskproto.ScheduleOptions.ScheduleType"0\n\x0cScheduleType\x12\x11\n\rinterval_type\x10\x00\x12\r\n\tcron_type\x10\x01\x42\x0b\n\t_intervalB\x07\n\x05_cronB\x0c\n\n_time_zone"t\n\x10WarehouseOptions\x12\x16\n\twarehouse\x18\x01 \x01(\tH\x00\x88\x01\x01\x12!\n\x14using_warehouse_size\x18\x02 \x01(\tH\x01\x88\x01\x01\x42\x0c\n\n_warehouseB\x17\n\x15_using_warehouse_size"\x93\x03\n\x11\x43reateTaskRequest\x12\x11\n\ttask_name\x18\x01 \x01(\t\x12\x11\n\ttenant_id\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x03 \x01(\t\x12\r\n\x05owner\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x36\n\x11warehouse_options\x18\x08 \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12,\n\x1fsuspend_task_after_num_failures\x18\t \x01(\x05H\x01\x88\x01\x01\x12\x14\n\x0cif_not_exist\x18\n \x01(\x08\x12\r\n\x05\x61\x66ter\x18\x0b \x03(\t\x12\x1b\n\x0ewhen_condition\x18\x0c \x01(\tH\x02\x88\x01\x01\x42\n\n\x08_commentB"\n _suspend_task_after_num_failuresB\x11\n\x0f_when_condition"8\n\tTaskError\x12\x0c\n\x04kind\x18\x01 \x01(\t\x12\x0f\n\x07message\x18\x02 \x01(\t\x12\x0c\n\x04\x63ode\x18\x03 \x01(\x05"Y\n\x12\x43reateTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x12\x0f\n\x07task_id\x18\x02 \x01(\x04\x42\x08\n\x06_error"I\n\x0f\x44ropTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x10\n\x08if_exist\x18\x03 \x01(\x08"F\n\x10\x44ropTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error":\n\x12\x45xecuteTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t"I\n\x13\x45xecuteTaskResponse\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error"M\n\x13\x44\x65scribeTaskRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x10\n\x08if_exist\x18\x03 \x01(\x08"\xd0\x04\n\x04Task\x12\x0f\n\x07task_id\x18\x01 \x01(\x04\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x36\n\x11warehouse_options\x18\x08 \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12\x1e\n\x11next_scheduled_at\x18\t \x01(\tH\x01\x88\x01\x01\x12,\n\x1fsuspend_task_after_num_failures\x18\n \x01(\x05H\x02\x88\x01\x01\x12&\n\x06status\x18\x0c \x01(\x0e\x32\x16.taskproto.Task.Status\x12\x12\n\ncreated_at\x18\x0e \x01(\t\x12\x12\n\nupdated_at\x18\x0f \x01(\t\x12\x1e\n\x11last_suspended_at\x18\x10 \x01(\tH\x03\x88\x01\x01\x12\r\n\x05\x61\x66ter\x18\x11 \x03(\t\x12\x1b\n\x0ewhen_condition\x18\x12 \x01(\tH\x04\x88\x01\x01"$\n\x06Status\x12\r\n\tSuspended\x10\x00\x12\x0b\n\x07Started\x10\x01\x42\n\n\x08_commentB\x14\n\x12_next_scheduled_atB"\n _suspend_task_after_num_failuresB\x14\n\x12_last_suspended_atB\x11\n\x0f_when_condition"i\n\x14\x44\x65scribeTaskResponse\x12\x1d\n\x04task\x18\x01 \x01(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error"p\n\x10ShowTasksRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\tname_like\x18\x02 \x01(\t\x12\x14\n\x0cresult_limit\x18\x04 \x01(\x05\x12\x0e\n\x06owners\x18\x05 \x03(\t\x12\x10\n\x08task_ids\x18\x06 \x03(\t"g\n\x11ShowTasksResponse\x12\x1e\n\x05tasks\x18\x01 \x03(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error"\xf0\x04\n\x10\x41lterTaskRequest\x12\x11\n\ttask_name\x18\x01 \x01(\t\x12\x11\n\ttenant_id\x18\x02 \x01(\t\x12\x17\n\nquery_text\x18\x03 \x01(\tH\x00\x88\x01\x01\x12\x14\n\x07\x63omment\x18\x04 \x01(\tH\x01\x88\x01\x01\x12\x42\n\x0f\x61lter_task_type\x18\x05 \x01(\x0e\x32).taskproto.AlterTaskRequest.AlterTaskType\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x10\n\x08if_exist\x18\x08 \x01(\x08\x12\x36\n\x11warehouse_options\x18\t \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12,\n\x1fsuspend_task_after_num_failures\x18\n \x01(\x05H\x02\x88\x01\x01\x12\x1b\n\x0ewhen_condition\x18\x0b \x01(\tH\x03\x88\x01\x01\x12\x11\n\tadd_after\x18\x0c \x03(\t\x12\x14\n\x0cremove_after\x18\r \x03(\t"n\n\rAlterTaskType\x12\x0b\n\x07Suspend\x10\x00\x12\n\n\x06Resume\x10\x01\x12\x07\n\x03Set\x10\x02\x12\x0c\n\x08ModifyAs\x10\x03\x12\x0e\n\nModifyWhen\x10\x04\x12\x0c\n\x08\x41\x64\x64\x41\x66ter\x10\x05\x12\x0f\n\x0bRemoveAfter\x10\x06\x42\r\n\x0b_query_textB\n\n\x08_commentB"\n _suspend_task_after_num_failuresB\x11\n\x0f_when_condition"f\n\x11\x41lterTaskResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x12\x1d\n\x04task\x18\x02 \x01(\x0b\x32\x0f.taskproto.TaskB\x08\n\x06_error"\xc1\x01\n\x13ShowTaskRunsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x1c\n\x14scheduled_time_start\x18\x02 \x01(\t\x12\x1a\n\x12scheduled_time_end\x18\x03 \x01(\t\x12\x14\n\x0cresult_limit\x18\x04 \x01(\x05\x12\x12\n\nerror_only\x18\x05 \x01(\x08\x12\x0e\n\x06owners\x18\x06 \x03(\t\x12\x10\n\x08task_ids\x18\x07 \x03(\t\x12\x11\n\ttask_name\x18\x08 \x01(\t"\xcc\x04\n\x07TaskRun\x12\x0f\n\x07task_id\x18\x01 \x01(\x04\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x12\n\nquery_text\x18\x04 \x01(\t\x12\x14\n\x07\x63omment\x18\x05 \x01(\tH\x00\x88\x01\x01\x12\r\n\x05owner\x18\x06 \x01(\t\x12\x34\n\x10schedule_options\x18\x07 \x01(\x0b\x32\x1a.taskproto.ScheduleOptions\x12\x0e\n\x06run_id\x18\x08 \x01(\t\x12\x16\n\x0e\x61ttempt_number\x18\t \x01(\x05\x12\x36\n\x11warehouse_options\x18\n \x01(\x0b\x32\x1b.taskproto.WarehouseOptions\x12\'\n\x05state\x18\x0b \x01(\x0e\x32\x18.taskproto.TaskRun.State\x12\x12\n\nerror_code\x18\x0c \x01(\x03\x12\x1a\n\rerror_message\x18\r \x01(\tH\x01\x88\x01\x01\x12\x16\n\x0escheduled_time\x18\x0e \x01(\t\x12\x1b\n\x0e\x63ompleted_time\x18\x10 \x01(\tH\x02\x88\x01\x01\x12\x10\n\x08query_id\x18\x11 \x01(\t\x12\x16\n\x0e\x63ondition_text\x18\x12 \x01(\t\x12\x14\n\x0croot_task_id\x18\x13 \x01(\t"O\n\x05State\x12\r\n\tSCHEDULED\x10\x00\x12\r\n\tEXECUTING\x10\x01\x12\r\n\tSUCCEEDED\x10\x02\x12\n\n\x06\x46\x41ILED\x10\x03\x12\r\n\tCANCELLED\x10\x04\x42\n\n\x08_commentB\x10\n\x0e_error_messageB\x11\n\x0f_completed_time"q\n\x14ShowTaskRunsResponse\x12%\n\ttask_runs\x18\x01 \x03(\x0b\x32\x12.taskproto.TaskRun\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error"S\n\x18GetTaskDependentsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t\x12\x11\n\trecursive\x18\x03 \x01(\x08"n\n\x19GetTaskDependentsResponse\x12\x1d\n\x04task\x18\x01 \x03(\x0b\x32\x0f.taskproto.Task\x12(\n\x05\x65rror\x18\x02 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error"C\n\x1b\x45nableTaskDependentsRequest\x12\x11\n\ttenant_id\x18\x01 \x01(\t\x12\x11\n\ttask_name\x18\x02 \x01(\t"R\n\x1c\x45nableTaskDependentsResponse\x12(\n\x05\x65rror\x18\x01 \x01(\x0b\x32\x14.taskproto.TaskErrorH\x00\x88\x01\x01\x42\x08\n\x06_error2\xe6\x05\n\x0bTaskService\x12I\n\nCreateTask\x12\x1c.taskproto.CreateTaskRequest\x1a\x1d.taskproto.CreateTaskResponse\x12O\n\x0c\x44\x65scribeTask\x12\x1e.taskproto.DescribeTaskRequest\x1a\x1f.taskproto.DescribeTaskResponse\x12L\n\x0b\x45xecuteTask\x12\x1d.taskproto.ExecuteTaskRequest\x1a\x1e.taskproto.ExecuteTaskResponse\x12\x43\n\x08\x44ropTask\x12\x1a.taskproto.DropTaskRequest\x1a\x1b.taskproto.DropTaskResponse\x12\x46\n\tAlterTask\x12\x1b.taskproto.AlterTaskRequest\x1a\x1c.taskproto.AlterTaskResponse\x12\x46\n\tShowTasks\x12\x1b.taskproto.ShowTasksRequest\x1a\x1c.taskproto.ShowTasksResponse\x12O\n\x0cShowTaskRuns\x12\x1e.taskproto.ShowTaskRunsRequest\x1a\x1f.taskproto.ShowTaskRunsResponse\x12^\n\x11GetTaskDependents\x12#.taskproto.GetTaskDependentsRequest\x1a$.taskproto.GetTaskDependentsResponse\x12g\n\x14\x45nableTaskDependents\x12&.taskproto.EnableTaskDependentsRequest\x1a\'.taskproto.EnableTaskDependentsResponseB!Z\x1f\x64\x61tabend.com/cloudcontrol/protob\x06proto3' +) _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) -_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'task_pb2', _globals) +_builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, "task_pb2", _globals) if _descriptor._USE_C_DESCRIPTORS == False: - DESCRIPTOR._options = None - DESCRIPTOR._serialized_options = b'Z\037databend.com/cloudcontrol/proto' - _globals['_SCHEDULEOPTIONS']._serialized_start=26 - _globals['_SCHEDULEOPTIONS']._serialized_end=259 - _globals['_SCHEDULEOPTIONS_SCHEDULETYPE']._serialized_start=175 - _globals['_SCHEDULEOPTIONS_SCHEDULETYPE']._serialized_end=223 - _globals['_WAREHOUSEOPTIONS']._serialized_start=261 - _globals['_WAREHOUSEOPTIONS']._serialized_end=377 - _globals['_CREATETASKREQUEST']._serialized_start=380 - _globals['_CREATETASKREQUEST']._serialized_end=783 - _globals['_TASKERROR']._serialized_start=785 - _globals['_TASKERROR']._serialized_end=841 - _globals['_CREATETASKRESPONSE']._serialized_start=843 - _globals['_CREATETASKRESPONSE']._serialized_end=932 - _globals['_DROPTASKREQUEST']._serialized_start=934 - _globals['_DROPTASKREQUEST']._serialized_end=1007 - _globals['_DROPTASKRESPONSE']._serialized_start=1009 - _globals['_DROPTASKRESPONSE']._serialized_end=1079 - _globals['_EXECUTETASKREQUEST']._serialized_start=1081 - _globals['_EXECUTETASKREQUEST']._serialized_end=1139 - _globals['_EXECUTETASKRESPONSE']._serialized_start=1141 - _globals['_EXECUTETASKRESPONSE']._serialized_end=1214 - _globals['_DESCRIBETASKREQUEST']._serialized_start=1216 - _globals['_DESCRIBETASKREQUEST']._serialized_end=1293 - _globals['_TASK']._serialized_start=1296 - _globals['_TASK']._serialized_end=1888 - _globals['_TASK_STATUS']._serialized_start=1741 - _globals['_TASK_STATUS']._serialized_end=1777 - _globals['_DESCRIBETASKRESPONSE']._serialized_start=1890 - _globals['_DESCRIBETASKRESPONSE']._serialized_end=1995 - _globals['_SHOWTASKSREQUEST']._serialized_start=1997 - _globals['_SHOWTASKSREQUEST']._serialized_end=2109 - _globals['_SHOWTASKSRESPONSE']._serialized_start=2111 - _globals['_SHOWTASKSRESPONSE']._serialized_end=2214 - _globals['_ALTERTASKREQUEST']._serialized_start=2217 - _globals['_ALTERTASKREQUEST']._serialized_end=2841 - _globals['_ALTERTASKREQUEST_ALTERTASKTYPE']._serialized_start=2649 - _globals['_ALTERTASKREQUEST_ALTERTASKTYPE']._serialized_end=2759 - _globals['_ALTERTASKRESPONSE']._serialized_start=2843 - _globals['_ALTERTASKRESPONSE']._serialized_end=2945 - _globals['_SHOWTASKRUNSREQUEST']._serialized_start=2948 - _globals['_SHOWTASKRUNSREQUEST']._serialized_end=3141 - _globals['_TASKRUN']._serialized_start=3144 - _globals['_TASKRUN']._serialized_end=3732 - _globals['_TASKRUN_STATE']._serialized_start=3604 - _globals['_TASKRUN_STATE']._serialized_end=3683 - _globals['_SHOWTASKRUNSRESPONSE']._serialized_start=3734 - _globals['_SHOWTASKRUNSRESPONSE']._serialized_end=3847 - _globals['_GETTASKDEPENDENTSREQUEST']._serialized_start=3849 - _globals['_GETTASKDEPENDENTSREQUEST']._serialized_end=3932 - _globals['_GETTASKDEPENDENTSRESPONSE']._serialized_start=3934 - _globals['_GETTASKDEPENDENTSRESPONSE']._serialized_end=4044 - _globals['_ENABLETASKDEPENDENTSREQUEST']._serialized_start=4046 - _globals['_ENABLETASKDEPENDENTSREQUEST']._serialized_end=4113 - _globals['_ENABLETASKDEPENDENTSRESPONSE']._serialized_start=4115 - _globals['_ENABLETASKDEPENDENTSRESPONSE']._serialized_end=4197 - _globals['_TASKSERVICE']._serialized_start=4200 - _globals['_TASKSERVICE']._serialized_end=4942 + DESCRIPTOR._options = None + DESCRIPTOR._serialized_options = b"Z\037databend.com/cloudcontrol/proto" + _globals["_SCHEDULEOPTIONS"]._serialized_start = 26 + _globals["_SCHEDULEOPTIONS"]._serialized_end = 259 + _globals["_SCHEDULEOPTIONS_SCHEDULETYPE"]._serialized_start = 175 + _globals["_SCHEDULEOPTIONS_SCHEDULETYPE"]._serialized_end = 223 + _globals["_WAREHOUSEOPTIONS"]._serialized_start = 261 + _globals["_WAREHOUSEOPTIONS"]._serialized_end = 377 + _globals["_CREATETASKREQUEST"]._serialized_start = 380 + _globals["_CREATETASKREQUEST"]._serialized_end = 783 + _globals["_TASKERROR"]._serialized_start = 785 + _globals["_TASKERROR"]._serialized_end = 841 + _globals["_CREATETASKRESPONSE"]._serialized_start = 843 + _globals["_CREATETASKRESPONSE"]._serialized_end = 932 + _globals["_DROPTASKREQUEST"]._serialized_start = 934 + _globals["_DROPTASKREQUEST"]._serialized_end = 1007 + _globals["_DROPTASKRESPONSE"]._serialized_start = 1009 + _globals["_DROPTASKRESPONSE"]._serialized_end = 1079 + _globals["_EXECUTETASKREQUEST"]._serialized_start = 1081 + _globals["_EXECUTETASKREQUEST"]._serialized_end = 1139 + _globals["_EXECUTETASKRESPONSE"]._serialized_start = 1141 + _globals["_EXECUTETASKRESPONSE"]._serialized_end = 1214 + _globals["_DESCRIBETASKREQUEST"]._serialized_start = 1216 + _globals["_DESCRIBETASKREQUEST"]._serialized_end = 1293 + _globals["_TASK"]._serialized_start = 1296 + _globals["_TASK"]._serialized_end = 1888 + _globals["_TASK_STATUS"]._serialized_start = 1741 + _globals["_TASK_STATUS"]._serialized_end = 1777 + _globals["_DESCRIBETASKRESPONSE"]._serialized_start = 1890 + _globals["_DESCRIBETASKRESPONSE"]._serialized_end = 1995 + _globals["_SHOWTASKSREQUEST"]._serialized_start = 1997 + _globals["_SHOWTASKSREQUEST"]._serialized_end = 2109 + _globals["_SHOWTASKSRESPONSE"]._serialized_start = 2111 + _globals["_SHOWTASKSRESPONSE"]._serialized_end = 2214 + _globals["_ALTERTASKREQUEST"]._serialized_start = 2217 + _globals["_ALTERTASKREQUEST"]._serialized_end = 2841 + _globals["_ALTERTASKREQUEST_ALTERTASKTYPE"]._serialized_start = 2649 + _globals["_ALTERTASKREQUEST_ALTERTASKTYPE"]._serialized_end = 2759 + _globals["_ALTERTASKRESPONSE"]._serialized_start = 2843 + _globals["_ALTERTASKRESPONSE"]._serialized_end = 2945 + _globals["_SHOWTASKRUNSREQUEST"]._serialized_start = 2948 + _globals["_SHOWTASKRUNSREQUEST"]._serialized_end = 3141 + _globals["_TASKRUN"]._serialized_start = 3144 + _globals["_TASKRUN"]._serialized_end = 3732 + _globals["_TASKRUN_STATE"]._serialized_start = 3604 + _globals["_TASKRUN_STATE"]._serialized_end = 3683 + _globals["_SHOWTASKRUNSRESPONSE"]._serialized_start = 3734 + _globals["_SHOWTASKRUNSRESPONSE"]._serialized_end = 3847 + _globals["_GETTASKDEPENDENTSREQUEST"]._serialized_start = 3849 + _globals["_GETTASKDEPENDENTSREQUEST"]._serialized_end = 3932 + _globals["_GETTASKDEPENDENTSRESPONSE"]._serialized_start = 3934 + _globals["_GETTASKDEPENDENTSRESPONSE"]._serialized_end = 4044 + _globals["_ENABLETASKDEPENDENTSREQUEST"]._serialized_start = 4046 + _globals["_ENABLETASKDEPENDENTSREQUEST"]._serialized_end = 4113 + _globals["_ENABLETASKDEPENDENTSRESPONSE"]._serialized_start = 4115 + _globals["_ENABLETASKDEPENDENTSRESPONSE"]._serialized_end = 4197 + _globals["_TASKSERVICE"]._serialized_start = 4200 + _globals["_TASKSERVICE"]._serialized_end = 4942 # @@protoc_insertion_point(module_scope) diff --git a/tests/cloud_control_server/task_pb2_grpc.py b/tests/cloud_control_server/task_pb2_grpc.py index 52d0f5c54be27..274c826bb0696 100644 --- a/tests/cloud_control_server/task_pb2_grpc.py +++ b/tests/cloud_control_server/task_pb2_grpc.py @@ -15,50 +15,50 @@ def __init__(self, channel): channel: A grpc.Channel. """ self.CreateTask = channel.unary_unary( - '/taskproto.TaskService/CreateTask', - request_serializer=task__pb2.CreateTaskRequest.SerializeToString, - response_deserializer=task__pb2.CreateTaskResponse.FromString, - ) + "/taskproto.TaskService/CreateTask", + request_serializer=task__pb2.CreateTaskRequest.SerializeToString, + response_deserializer=task__pb2.CreateTaskResponse.FromString, + ) self.DescribeTask = channel.unary_unary( - '/taskproto.TaskService/DescribeTask', - request_serializer=task__pb2.DescribeTaskRequest.SerializeToString, - response_deserializer=task__pb2.DescribeTaskResponse.FromString, - ) + "/taskproto.TaskService/DescribeTask", + request_serializer=task__pb2.DescribeTaskRequest.SerializeToString, + response_deserializer=task__pb2.DescribeTaskResponse.FromString, + ) self.ExecuteTask = channel.unary_unary( - '/taskproto.TaskService/ExecuteTask', - request_serializer=task__pb2.ExecuteTaskRequest.SerializeToString, - response_deserializer=task__pb2.ExecuteTaskResponse.FromString, - ) + "/taskproto.TaskService/ExecuteTask", + request_serializer=task__pb2.ExecuteTaskRequest.SerializeToString, + response_deserializer=task__pb2.ExecuteTaskResponse.FromString, + ) self.DropTask = channel.unary_unary( - '/taskproto.TaskService/DropTask', - request_serializer=task__pb2.DropTaskRequest.SerializeToString, - response_deserializer=task__pb2.DropTaskResponse.FromString, - ) + "/taskproto.TaskService/DropTask", + request_serializer=task__pb2.DropTaskRequest.SerializeToString, + response_deserializer=task__pb2.DropTaskResponse.FromString, + ) self.AlterTask = channel.unary_unary( - '/taskproto.TaskService/AlterTask', - request_serializer=task__pb2.AlterTaskRequest.SerializeToString, - response_deserializer=task__pb2.AlterTaskResponse.FromString, - ) + "/taskproto.TaskService/AlterTask", + request_serializer=task__pb2.AlterTaskRequest.SerializeToString, + response_deserializer=task__pb2.AlterTaskResponse.FromString, + ) self.ShowTasks = channel.unary_unary( - '/taskproto.TaskService/ShowTasks', - request_serializer=task__pb2.ShowTasksRequest.SerializeToString, - response_deserializer=task__pb2.ShowTasksResponse.FromString, - ) + "/taskproto.TaskService/ShowTasks", + request_serializer=task__pb2.ShowTasksRequest.SerializeToString, + response_deserializer=task__pb2.ShowTasksResponse.FromString, + ) self.ShowTaskRuns = channel.unary_unary( - '/taskproto.TaskService/ShowTaskRuns', - request_serializer=task__pb2.ShowTaskRunsRequest.SerializeToString, - response_deserializer=task__pb2.ShowTaskRunsResponse.FromString, - ) + "/taskproto.TaskService/ShowTaskRuns", + request_serializer=task__pb2.ShowTaskRunsRequest.SerializeToString, + response_deserializer=task__pb2.ShowTaskRunsResponse.FromString, + ) self.GetTaskDependents = channel.unary_unary( - '/taskproto.TaskService/GetTaskDependents', - request_serializer=task__pb2.GetTaskDependentsRequest.SerializeToString, - response_deserializer=task__pb2.GetTaskDependentsResponse.FromString, - ) + "/taskproto.TaskService/GetTaskDependents", + request_serializer=task__pb2.GetTaskDependentsRequest.SerializeToString, + response_deserializer=task__pb2.GetTaskDependentsResponse.FromString, + ) self.EnableTaskDependents = channel.unary_unary( - '/taskproto.TaskService/EnableTaskDependents', - request_serializer=task__pb2.EnableTaskDependentsRequest.SerializeToString, - response_deserializer=task__pb2.EnableTaskDependentsResponse.FromString, - ) + "/taskproto.TaskService/EnableTaskDependents", + request_serializer=task__pb2.EnableTaskDependentsRequest.SerializeToString, + response_deserializer=task__pb2.EnableTaskDependentsResponse.FromString, + ) class TaskServiceServicer(object): @@ -67,264 +67,373 @@ class TaskServiceServicer(object): def CreateTask(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def DescribeTask(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def ExecuteTask(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def DropTask(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def AlterTask(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def ShowTasks(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def ShowTaskRuns(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def GetTaskDependents(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def EnableTaskDependents(self, request, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) - context.set_details('Method not implemented!') - raise NotImplementedError('Method not implemented!') + context.set_details("Method not implemented!") + raise NotImplementedError("Method not implemented!") def add_TaskServiceServicer_to_server(servicer, server): rpc_method_handlers = { - 'CreateTask': grpc.unary_unary_rpc_method_handler( - servicer.CreateTask, - request_deserializer=task__pb2.CreateTaskRequest.FromString, - response_serializer=task__pb2.CreateTaskResponse.SerializeToString, - ), - 'DescribeTask': grpc.unary_unary_rpc_method_handler( - servicer.DescribeTask, - request_deserializer=task__pb2.DescribeTaskRequest.FromString, - response_serializer=task__pb2.DescribeTaskResponse.SerializeToString, - ), - 'ExecuteTask': grpc.unary_unary_rpc_method_handler( - servicer.ExecuteTask, - request_deserializer=task__pb2.ExecuteTaskRequest.FromString, - response_serializer=task__pb2.ExecuteTaskResponse.SerializeToString, - ), - 'DropTask': grpc.unary_unary_rpc_method_handler( - servicer.DropTask, - request_deserializer=task__pb2.DropTaskRequest.FromString, - response_serializer=task__pb2.DropTaskResponse.SerializeToString, - ), - 'AlterTask': grpc.unary_unary_rpc_method_handler( - servicer.AlterTask, - request_deserializer=task__pb2.AlterTaskRequest.FromString, - response_serializer=task__pb2.AlterTaskResponse.SerializeToString, - ), - 'ShowTasks': grpc.unary_unary_rpc_method_handler( - servicer.ShowTasks, - request_deserializer=task__pb2.ShowTasksRequest.FromString, - response_serializer=task__pb2.ShowTasksResponse.SerializeToString, - ), - 'ShowTaskRuns': grpc.unary_unary_rpc_method_handler( - servicer.ShowTaskRuns, - request_deserializer=task__pb2.ShowTaskRunsRequest.FromString, - response_serializer=task__pb2.ShowTaskRunsResponse.SerializeToString, - ), - 'GetTaskDependents': grpc.unary_unary_rpc_method_handler( - servicer.GetTaskDependents, - request_deserializer=task__pb2.GetTaskDependentsRequest.FromString, - response_serializer=task__pb2.GetTaskDependentsResponse.SerializeToString, - ), - 'EnableTaskDependents': grpc.unary_unary_rpc_method_handler( - servicer.EnableTaskDependents, - request_deserializer=task__pb2.EnableTaskDependentsRequest.FromString, - response_serializer=task__pb2.EnableTaskDependentsResponse.SerializeToString, - ), + "CreateTask": grpc.unary_unary_rpc_method_handler( + servicer.CreateTask, + request_deserializer=task__pb2.CreateTaskRequest.FromString, + response_serializer=task__pb2.CreateTaskResponse.SerializeToString, + ), + "DescribeTask": grpc.unary_unary_rpc_method_handler( + servicer.DescribeTask, + request_deserializer=task__pb2.DescribeTaskRequest.FromString, + response_serializer=task__pb2.DescribeTaskResponse.SerializeToString, + ), + "ExecuteTask": grpc.unary_unary_rpc_method_handler( + servicer.ExecuteTask, + request_deserializer=task__pb2.ExecuteTaskRequest.FromString, + response_serializer=task__pb2.ExecuteTaskResponse.SerializeToString, + ), + "DropTask": grpc.unary_unary_rpc_method_handler( + servicer.DropTask, + request_deserializer=task__pb2.DropTaskRequest.FromString, + response_serializer=task__pb2.DropTaskResponse.SerializeToString, + ), + "AlterTask": grpc.unary_unary_rpc_method_handler( + servicer.AlterTask, + request_deserializer=task__pb2.AlterTaskRequest.FromString, + response_serializer=task__pb2.AlterTaskResponse.SerializeToString, + ), + "ShowTasks": grpc.unary_unary_rpc_method_handler( + servicer.ShowTasks, + request_deserializer=task__pb2.ShowTasksRequest.FromString, + response_serializer=task__pb2.ShowTasksResponse.SerializeToString, + ), + "ShowTaskRuns": grpc.unary_unary_rpc_method_handler( + servicer.ShowTaskRuns, + request_deserializer=task__pb2.ShowTaskRunsRequest.FromString, + response_serializer=task__pb2.ShowTaskRunsResponse.SerializeToString, + ), + "GetTaskDependents": grpc.unary_unary_rpc_method_handler( + servicer.GetTaskDependents, + request_deserializer=task__pb2.GetTaskDependentsRequest.FromString, + response_serializer=task__pb2.GetTaskDependentsResponse.SerializeToString, + ), + "EnableTaskDependents": grpc.unary_unary_rpc_method_handler( + servicer.EnableTaskDependents, + request_deserializer=task__pb2.EnableTaskDependentsRequest.FromString, + response_serializer=task__pb2.EnableTaskDependentsResponse.SerializeToString, + ), } generic_handler = grpc.method_handlers_generic_handler( - 'taskproto.TaskService', rpc_method_handlers) + "taskproto.TaskService", rpc_method_handlers + ) server.add_generic_rpc_handlers((generic_handler,)) - # This class is part of an EXPERIMENTAL API. +# This class is part of an EXPERIMENTAL API. class TaskService(object): """Missing associated documentation comment in .proto file.""" @staticmethod - def CreateTask(request, + def CreateTask( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/CreateTask', + "/taskproto.TaskService/CreateTask", task__pb2.CreateTaskRequest.SerializeToString, task__pb2.CreateTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def DescribeTask(request, + def DescribeTask( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/DescribeTask', + "/taskproto.TaskService/DescribeTask", task__pb2.DescribeTaskRequest.SerializeToString, task__pb2.DescribeTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def ExecuteTask(request, + def ExecuteTask( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/ExecuteTask', + "/taskproto.TaskService/ExecuteTask", task__pb2.ExecuteTaskRequest.SerializeToString, task__pb2.ExecuteTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def DropTask(request, + def DropTask( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/DropTask', + "/taskproto.TaskService/DropTask", task__pb2.DropTaskRequest.SerializeToString, task__pb2.DropTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def AlterTask(request, + def AlterTask( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/AlterTask', + "/taskproto.TaskService/AlterTask", task__pb2.AlterTaskRequest.SerializeToString, task__pb2.AlterTaskResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def ShowTasks(request, + def ShowTasks( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/ShowTasks', + "/taskproto.TaskService/ShowTasks", task__pb2.ShowTasksRequest.SerializeToString, task__pb2.ShowTasksResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def ShowTaskRuns(request, + def ShowTaskRuns( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/ShowTaskRuns', + "/taskproto.TaskService/ShowTaskRuns", task__pb2.ShowTaskRunsRequest.SerializeToString, task__pb2.ShowTaskRunsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def GetTaskDependents(request, + def GetTaskDependents( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/GetTaskDependents', + "/taskproto.TaskService/GetTaskDependents", task__pb2.GetTaskDependentsRequest.SerializeToString, task__pb2.GetTaskDependentsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + ) @staticmethod - def EnableTaskDependents(request, + def EnableTaskDependents( + request, + target, + options=(), + channel_credentials=None, + call_credentials=None, + insecure=False, + compression=None, + wait_for_ready=None, + timeout=None, + metadata=None, + ): + return grpc.experimental.unary_unary( + request, target, - options=(), - channel_credentials=None, - call_credentials=None, - insecure=False, - compression=None, - wait_for_ready=None, - timeout=None, - metadata=None): - return grpc.experimental.unary_unary(request, target, '/taskproto.TaskService/EnableTaskDependents', + "/taskproto.TaskService/EnableTaskDependents", task__pb2.EnableTaskDependentsRequest.SerializeToString, task__pb2.EnableTaskDependentsResponse.FromString, - options, channel_credentials, - insecure, call_credentials, compression, wait_for_ready, timeout, metadata) + options, + channel_credentials, + insecure, + call_credentials, + compression, + wait_for_ready, + timeout, + metadata, + )