Skip to content

Commit

Permalink
fix: Generate Python Code from plugin-pb (#50)
Browse files Browse the repository at this point in the history 
This PR was created by a scheduled workflow to regenerate the Python code from `plugin-pb`.
  • Loading branch information
@cq-bot
cq-bot authored Jan 1, 2024
1 parent 411af61 commit 3360e7e
Show file tree
Hide file tree
Showing 4 changed files with 48 additions and 46 deletions.
5 changes: 3 additions & 2 deletions cloudquery/discovery_v1/discovery_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions cloudquery/discovery_v1/discovery_pb2.pyi
View file
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,12 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Optional as _Op
DESCRIPTOR: _descriptor.FileDescriptor

class GetVersions(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
class Response(_message.Message):
__slots__ = ["versions"]
__slots__ = ("versions",)
VERSIONS_FIELD_NUMBER: _ClassVar[int]
versions: _containers.RepeatedScalarFieldContainer[int]
def __init__(self, versions: _Optional[_Iterable[int]] = ...) -> None: ...
Expand Down
9 changes: 5 additions & 4 deletions cloudquery/plugin_v3/plugin_pb2.py
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

74 changes: 37 additions & 37 deletions cloudquery/plugin_v3/plugin_pb2.pyi
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,47 +8,47 @@ from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Map
DESCRIPTOR: _descriptor.FileDescriptor

class GetName(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
class Response(_message.Message):
__slots__ = ["name"]
__slots__ = ("name",)
NAME_FIELD_NUMBER: _ClassVar[int]
name: str
def __init__(self, name: _Optional[str] = ...) -> None: ...
def __init__(self) -> None: ...

class GetVersion(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
class Response(_message.Message):
__slots__ = ["version"]
__slots__ = ("version",)
VERSION_FIELD_NUMBER: _ClassVar[int]
version: str
def __init__(self, version: _Optional[str] = ...) -> None: ...
def __init__(self) -> None: ...

class Init(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = ["spec", "no_connection"]
__slots__ = ("spec", "no_connection")
SPEC_FIELD_NUMBER: _ClassVar[int]
NO_CONNECTION_FIELD_NUMBER: _ClassVar[int]
spec: bytes
no_connection: bool
def __init__(self, spec: _Optional[bytes] = ..., no_connection: bool = ...) -> None: ...
class Response(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
def __init__(self) -> None: ...

class GetTables(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = ["tables", "skip_tables", "skip_dependent_tables"]
__slots__ = ("tables", "skip_tables", "skip_dependent_tables")
TABLES_FIELD_NUMBER: _ClassVar[int]
SKIP_TABLES_FIELD_NUMBER: _ClassVar[int]
SKIP_DEPENDENT_TABLES_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -57,26 +57,26 @@ class GetTables(_message.Message):
skip_dependent_tables: bool
def __init__(self, tables: _Optional[_Iterable[str]] = ..., skip_tables: _Optional[_Iterable[str]] = ..., skip_dependent_tables: bool = ...) -> None: ...
class Response(_message.Message):
__slots__ = ["tables"]
__slots__ = ("tables",)
TABLES_FIELD_NUMBER: _ClassVar[int]
tables: _containers.RepeatedScalarFieldContainer[bytes]
def __init__(self, tables: _Optional[_Iterable[bytes]] = ...) -> None: ...
def __init__(self) -> None: ...

class Sync(_message.Message):
__slots__ = []
__slots__ = ()
class MessageInsert(_message.Message):
__slots__ = ["record"]
__slots__ = ("record",)
RECORD_FIELD_NUMBER: _ClassVar[int]
record: bytes
def __init__(self, record: _Optional[bytes] = ...) -> None: ...
class MessageMigrateTable(_message.Message):
__slots__ = ["table"]
__slots__ = ("table",)
TABLE_FIELD_NUMBER: _ClassVar[int]
table: bytes
def __init__(self, table: _Optional[bytes] = ...) -> None: ...
class MessageDeleteRecord(_message.Message):
__slots__ = ["table_name", "where_clause", "table_relations"]
__slots__ = ("table_name", "where_clause", "table_relations")
TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
WHERE_CLAUSE_FIELD_NUMBER: _ClassVar[int]
TABLE_RELATIONS_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -85,14 +85,14 @@ class Sync(_message.Message):
table_relations: _containers.RepeatedCompositeFieldContainer[TableRelation]
def __init__(self, table_name: _Optional[str] = ..., where_clause: _Optional[_Iterable[_Union[PredicatesGroup, _Mapping]]] = ..., table_relations: _Optional[_Iterable[_Union[TableRelation, _Mapping]]] = ...) -> None: ...
class BackendOptions(_message.Message):
__slots__ = ["table_name", "connection"]
__slots__ = ("table_name", "connection")
TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
CONNECTION_FIELD_NUMBER: _ClassVar[int]
table_name: str
connection: str
def __init__(self, table_name: _Optional[str] = ..., connection: _Optional[str] = ...) -> None: ...
class Request(_message.Message):
__slots__ = ["tables", "skip_tables", "skip_dependent_tables", "deterministic_cq_id", "backend"]
__slots__ = ("tables", "skip_tables", "skip_dependent_tables", "deterministic_cq_id", "backend")
TABLES_FIELD_NUMBER: _ClassVar[int]
SKIP_TABLES_FIELD_NUMBER: _ClassVar[int]
SKIP_DEPENDENT_TABLES_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -105,7 +105,7 @@ class Sync(_message.Message):
backend: Sync.BackendOptions
def __init__(self, tables: _Optional[_Iterable[str]] = ..., skip_tables: _Optional[_Iterable[str]] = ..., skip_dependent_tables: bool = ..., deterministic_cq_id: bool = ..., backend: _Optional[_Union[Sync.BackendOptions, _Mapping]] = ...) -> None: ...
class Response(_message.Message):
__slots__ = ["migrate_table", "insert", "delete_record"]
__slots__ = ("migrate_table", "insert", "delete_record")
MIGRATE_TABLE_FIELD_NUMBER: _ClassVar[int]
INSERT_FIELD_NUMBER: _ClassVar[int]
DELETE_RECORD_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -116,31 +116,31 @@ class Sync(_message.Message):
def __init__(self) -> None: ...

class Read(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = ["table"]
__slots__ = ("table",)
TABLE_FIELD_NUMBER: _ClassVar[int]
table: bytes
def __init__(self, table: _Optional[bytes] = ...) -> None: ...
class Response(_message.Message):
__slots__ = ["record"]
__slots__ = ("record",)
RECORD_FIELD_NUMBER: _ClassVar[int]
record: bytes
def __init__(self, record: _Optional[bytes] = ...) -> None: ...
def __init__(self) -> None: ...

class TableRelation(_message.Message):
__slots__ = ["table_name", "parent_table"]
__slots__ = ("table_name", "parent_table")
TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
PARENT_TABLE_FIELD_NUMBER: _ClassVar[int]
table_name: str
parent_table: str
def __init__(self, table_name: _Optional[str] = ..., parent_table: _Optional[str] = ...) -> None: ...

class Predicate(_message.Message):
__slots__ = ["operator", "column", "record"]
__slots__ = ("operator", "column", "record")
class Operator(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
__slots__ = []
__slots__ = ()
EQ: _ClassVar[Predicate.Operator]
EQ: Predicate.Operator
OPERATOR_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -152,9 +152,9 @@ class Predicate(_message.Message):
def __init__(self, operator: _Optional[_Union[Predicate.Operator, str]] = ..., column: _Optional[str] = ..., record: _Optional[bytes] = ...) -> None: ...

class PredicatesGroup(_message.Message):
__slots__ = ["grouping_type", "predicates"]
__slots__ = ("grouping_type", "predicates")
class GroupingType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
__slots__ = []
__slots__ = ()
AND: _ClassVar[PredicatesGroup.GroupingType]
OR: _ClassVar[PredicatesGroup.GroupingType]
AND: PredicatesGroup.GroupingType
Expand All @@ -166,21 +166,21 @@ class PredicatesGroup(_message.Message):
def __init__(self, grouping_type: _Optional[_Union[PredicatesGroup.GroupingType, str]] = ..., predicates: _Optional[_Iterable[_Union[Predicate, _Mapping]]] = ...) -> None: ...

class Write(_message.Message):
__slots__ = []
__slots__ = ()
class MessageMigrateTable(_message.Message):
__slots__ = ["table", "migrate_force"]
__slots__ = ("table", "migrate_force")
TABLE_FIELD_NUMBER: _ClassVar[int]
MIGRATE_FORCE_FIELD_NUMBER: _ClassVar[int]
table: bytes
migrate_force: bool
def __init__(self, table: _Optional[bytes] = ..., migrate_force: bool = ...) -> None: ...
class MessageInsert(_message.Message):
__slots__ = ["record"]
__slots__ = ("record",)
RECORD_FIELD_NUMBER: _ClassVar[int]
record: bytes
def __init__(self, record: _Optional[bytes] = ...) -> None: ...
class MessageDeleteStale(_message.Message):
__slots__ = ["table", "source_name", "sync_time", "table_name"]
__slots__ = ("table", "source_name", "sync_time", "table_name")
TABLE_FIELD_NUMBER: _ClassVar[int]
SOURCE_NAME_FIELD_NUMBER: _ClassVar[int]
SYNC_TIME_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -191,7 +191,7 @@ class Write(_message.Message):
table_name: str
def __init__(self, table: _Optional[bytes] = ..., source_name: _Optional[str] = ..., sync_time: _Optional[_Union[_timestamp_pb2.Timestamp, _Mapping]] = ..., table_name: _Optional[str] = ...) -> None: ...
class MessageDeleteRecord(_message.Message):
__slots__ = ["table_name", "where_clause", "table_relations"]
__slots__ = ("table_name", "where_clause", "table_relations")
TABLE_NAME_FIELD_NUMBER: _ClassVar[int]
WHERE_CLAUSE_FIELD_NUMBER: _ClassVar[int]
TABLE_RELATIONS_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -200,7 +200,7 @@ class Write(_message.Message):
table_relations: _containers.RepeatedCompositeFieldContainer[TableRelation]
def __init__(self, table_name: _Optional[str] = ..., where_clause: _Optional[_Iterable[_Union[PredicatesGroup, _Mapping]]] = ..., table_relations: _Optional[_Iterable[_Union[TableRelation, _Mapping]]] = ...) -> None: ...
class Request(_message.Message):
__slots__ = ["migrate_table", "insert", "delete", "delete_record"]
__slots__ = ("migrate_table", "insert", "delete", "delete_record")
MIGRATE_TABLE_FIELD_NUMBER: _ClassVar[int]
INSERT_FIELD_NUMBER: _ClassVar[int]
DELETE_FIELD_NUMBER: _ClassVar[int]
Expand All @@ -211,16 +211,16 @@ class Write(_message.Message):
delete_record: Write.MessageDeleteRecord
def __init__(self, migrate_table: _Optional[_Union[Write.MessageMigrateTable, _Mapping]] = ..., insert: _Optional[_Union[Write.MessageInsert, _Mapping]] = ..., delete: _Optional[_Union[Write.MessageDeleteStale, _Mapping]] = ..., delete_record: _Optional[_Union[Write.MessageDeleteRecord, _Mapping]] = ...) -> None: ...
class Response(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
def __init__(self) -> None: ...

class Close(_message.Message):
__slots__ = []
__slots__ = ()
class Request(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
class Response(_message.Message):
__slots__ = []
__slots__ = ()
def __init__(self) -> None: ...
def __init__(self) -> None: ...

0 comments on commit 3360e7e

Please sign in to comment.