Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 1 addition & 3 deletions stubs/google-cloud-ndb/google/cloud/ndb/_batch.pyi
Original file line number Diff line number Diff line change
@@ -1,3 +1 @@
from _typeshed import Incomplete

def get_batch(batch_cls, options: Incomplete | None = ...): ...
def get_batch(batch_cls, options=None): ...
2 changes: 1 addition & 1 deletion stubs/google-cloud-ndb/google/cloud/ndb/_cache.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ class _GlobalCacheGetBatch(_GlobalCacheBatch):
def make_call(self): ...
def future_info(self, key): ...

def global_set(key, value, expires: Incomplete | None = ..., read: bool = ...): ...
def global_set(key, value, expires=None, read: bool = False): ...

class _GlobalCacheSetBatch(_GlobalCacheBatch):
expires: Incomplete
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ class Cursor:
@classmethod
def from_websafe_string(cls, urlsafe): ...
cursor: Incomplete
def __init__(self, cursor: Incomplete | None = ..., urlsafe: Incomplete | None = ...) -> None: ...
def __init__(self, cursor=None, urlsafe=None) -> None: ...
def to_websafe_string(self): ...
def urlsafe(self): ...
def __eq__(self, other): ...
Expand Down
8 changes: 3 additions & 5 deletions stubs/google-cloud-ndb/google/cloud/ndb/_options.pyi
Original file line number Diff line number Diff line change
@@ -1,5 +1,3 @@
from _typeshed import Incomplete

class Options:
__slots__ = (
"retries",
Expand All @@ -16,15 +14,15 @@ class Options:
"memcache_timeout",
)
@classmethod
def options(cls, wrapped, _disambiguate_from_model_properties: bool = ...): ...
def options(cls, wrapped, _disambiguate_from_model_properties: bool = False): ...
@classmethod
def slots(cls): ...
def __init__(self, config: Incomplete | None = ..., **kwargs) -> None: ...
def __init__(self, config=None, **kwargs) -> None: ...
def __eq__(self, other): ...
def __ne__(self, other): ...
def copy(self, **kwargs): ...
def items(self) -> None: ...

class ReadOptions(Options):
__slots__ = ("read_consistency", "read_policy", "transaction")
def __init__(self, config: Incomplete | None = ..., **kwargs) -> None: ...
def __init__(self, config=None, **kwargs) -> None: ...
26 changes: 7 additions & 19 deletions stubs/google-cloud-ndb/google/cloud/ndb/_transaction.pyi
Original file line number Diff line number Diff line change
@@ -1,20 +1,8 @@
from _typeshed import Incomplete

def in_transaction(): ...
def transaction(
callback, retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...
): ...
def transaction_async(
callback, retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...
): ...
def transaction_async_(
callback, retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...
): ...
def transactional(retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...): ...
def transactional_async(
retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...
): ...
def transactional_tasklet(
retries=..., read_only: bool = ..., join: bool = ..., xg: bool = ..., propagation: Incomplete | None = ...
): ...
def non_transactional(allow_existing: bool = ...): ...
def transaction(callback, retries=..., read_only: bool = False, join: bool = False, xg: bool = True, propagation=None): ...
def transaction_async(callback, retries=..., read_only: bool = False, join: bool = False, xg: bool = True, propagation=None): ...
def transaction_async_(callback, retries=..., read_only: bool = False, join: bool = False, xg: bool = True, propagation=None): ...
def transactional(retries=..., read_only: bool = False, join: bool = True, xg: bool = True, propagation=None): ...
def transactional_async(retries=..., read_only: bool = False, join: bool = True, xg: bool = True, propagation=None): ...
def transactional_tasklet(retries=..., read_only: bool = False, join: bool = True, xg: bool = True, propagation=None): ...
def non_transactional(allow_existing: bool = True): ...
18 changes: 9 additions & 9 deletions stubs/google-cloud-ndb/google/cloud/ndb/client.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -17,19 +17,19 @@ class Client:
database: str | None
def __init__(
self,
project: str | None = ...,
namespace: str | None = ...,
credentials: Incomplete | None = ...,
client_options: Incomplete | None = ...,
project: str | None = None,
namespace: str | None = None,
credentials=None,
client_options=None,
database: str | None = None,
) -> None: ...
@contextmanager
def context(
self,
namespace=...,
cache_policy: Callable[[key.Key], bool] | None = ...,
global_cache: Incomplete | None = ...,
global_cache_policy: Callable[[key.Key], bool] | None = ...,
global_cache_timeout_policy: Callable[[key.Key], int] | None = ...,
legacy_data: bool = ...,
cache_policy: Callable[[key.Key], bool] | None = None,
global_cache=None,
global_cache_policy: Callable[[key.Key], bool] | None = None,
global_cache_timeout_policy: Callable[[key.Key], int] | None = None,
legacy_data: bool = True,
) -> Generator[context_module.Context]: ...
38 changes: 19 additions & 19 deletions stubs/google-cloud-ndb/google/cloud/ndb/context.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@ class _LocalState:
@toplevel_context.setter
def toplevel_context(self, value) -> None: ...

def get_context(raise_context_error: bool = ...): ...
def get_toplevel_context(raise_context_error: bool = ...): ...
def get_context(raise_context_error: bool = True): ...
def get_toplevel_context(raise_context_error: bool = True): ...

class _ContextTuple(NamedTuple):
id: Incomplete
Expand All @@ -38,24 +38,24 @@ class _Context(_ContextTuple):
def __new__(
cls,
client,
id: Incomplete | None = ...,
id=None,
namespace=...,
eventloop: Incomplete | None = ...,
batches: Incomplete | None = ...,
commit_batches: Incomplete | None = ...,
transaction: Incomplete | None = ...,
cache: Incomplete | None = ...,
cache_policy: Incomplete | None = ...,
global_cache: Incomplete | None = ...,
global_cache_policy: Callable[[Key], bool] | None = ...,
global_cache_timeout_policy: Incomplete | None = ...,
datastore_policy: Incomplete | None = ...,
on_commit_callbacks: Incomplete | None = ...,
transaction_complete_callbacks: Incomplete | None = ...,
legacy_data: bool = ...,
retry: Incomplete | None = ...,
rpc_time: Incomplete | None = ...,
wait_time: Incomplete | None = ...,
eventloop=None,
batches=None,
commit_batches=None,
transaction=None,
cache=None,
cache_policy=None,
global_cache=None,
global_cache_policy: Callable[[Key], bool] | None = None,
global_cache_timeout_policy=None,
datastore_policy=None,
on_commit_callbacks=None,
transaction_complete_callbacks=None,
legacy_data: bool = True,
retry=None,
rpc_time=None,
wait_time=None,
): ...
def new(self, **kwargs): ...
rpc_time: int
Expand Down
24 changes: 12 additions & 12 deletions stubs/google-cloud-ndb/google/cloud/ndb/global_cache.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -12,45 +12,45 @@ class GlobalCache(metaclass=abc.ABCMeta):
@abc.abstractmethod
def get(self, keys): ...
@abc.abstractmethod
def set(self, items, expires: Incomplete | None = ...): ...
def set(self, items, expires=None): ...
@abc.abstractmethod
def delete(self, keys): ...
@abc.abstractmethod
def watch(self, items): ...
@abc.abstractmethod
def unwatch(self, keys): ...
@abc.abstractmethod
def compare_and_swap(self, items, expires: Incomplete | None = ...): ...
def compare_and_swap(self, items, expires=None): ...
@abc.abstractmethod
def clear(self): ...

class _InProcessGlobalCache(GlobalCache):
cache: Incomplete
def __init__(self) -> None: ...
def get(self, keys): ...
def set(self, items, expires: Incomplete | None = ...) -> None: ...
def set(self, items, expires=None) -> None: ...
def delete(self, keys) -> None: ...
def watch(self, items) -> None: ...
def unwatch(self, keys) -> None: ...
def compare_and_swap(self, items, expires: Incomplete | None = ...): ...
def compare_and_swap(self, items, expires=None): ...
def clear(self) -> None: ...

class RedisCache(GlobalCache):
transient_errors: Incomplete
@classmethod
def from_environment(cls, strict_read: bool = ..., strict_write: bool = ...) -> Self: ...
def from_environment(cls, strict_read: bool = False, strict_write: bool = True) -> Self: ...
redis: Incomplete
strict_read: Incomplete
strict_write: Incomplete
def __init__(self, redis, strict_read: bool = ..., strict_write: bool = ...) -> None: ...
def __init__(self, redis, strict_read: bool = False, strict_write: bool = True) -> None: ...
@property
def pipes(self): ...
def get(self, keys): ...
def set(self, items, expires: Incomplete | None = ...) -> None: ...
def set(self, items, expires=None) -> None: ...
def delete(self, keys) -> None: ...
def watch(self, items) -> None: ...
def unwatch(self, keys) -> None: ...
def compare_and_swap(self, items, expires: Incomplete | None = ...): ...
def compare_and_swap(self, items, expires=None): ...
def clear(self) -> None: ...

class MemcacheCache(GlobalCache):
Expand All @@ -61,17 +61,17 @@ class MemcacheCache(GlobalCache):

transient_errors: Incomplete
@classmethod
def from_environment(cls, max_pool_size: int = ..., strict_read: bool = ..., strict_write: bool = ...) -> Self: ...
def from_environment(cls, max_pool_size: int = 4, strict_read: bool = False, strict_write: bool = True) -> Self: ...
client: Incomplete
strict_read: Incomplete
strict_write: Incomplete
def __init__(self, client, strict_read: bool = ..., strict_write: bool = ...) -> None: ...
def __init__(self, client, strict_read: bool = False, strict_write: bool = True) -> None: ...
@property
def caskeys(self): ...
def get(self, keys): ...
def set(self, items, expires: Incomplete | None = ...): ...
def set(self, items, expires=None): ...
def delete(self, keys) -> None: ...
def watch(self, items) -> None: ...
def unwatch(self, keys) -> None: ...
def compare_and_swap(self, items, expires: Incomplete | None = ...): ...
def compare_and_swap(self, items, expires=None): ...
def clear(self) -> None: ...
108 changes: 54 additions & 54 deletions stubs/google-cloud-ndb/google/cloud/ndb/key.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -30,69 +30,69 @@ class Key:
def to_legacy_urlsafe(self, location_prefix): ...
def get(
self,
read_consistency: Incomplete | None = ...,
read_policy: Incomplete | None = ...,
transaction: Incomplete | None = ...,
retries: Incomplete | None = ...,
timeout: Incomplete | None = ...,
deadline: Incomplete | None = ...,
use_cache: Incomplete | None = ...,
use_global_cache: Incomplete | None = ...,
use_datastore: Incomplete | None = ...,
global_cache_timeout: Incomplete | None = ...,
use_memcache: Incomplete | None = ...,
memcache_timeout: Incomplete | None = ...,
max_memcache_items: Incomplete | None = ...,
force_writes: Incomplete | None = ...,
_options: Incomplete | None = ...,
read_consistency=None,
read_policy=None,
transaction=None,
retries=None,
timeout=None,
deadline=None,
use_cache=None,
use_global_cache=None,
use_datastore=None,
global_cache_timeout=None,
use_memcache=None,
memcache_timeout=None,
max_memcache_items=None,
force_writes=None,
_options=None,
): ...
def get_async(
self,
read_consistency: Incomplete | None = ...,
read_policy: Incomplete | None = ...,
transaction: Incomplete | None = ...,
retries: Incomplete | None = ...,
timeout: Incomplete | None = ...,
deadline: Incomplete | None = ...,
use_cache: Incomplete | None = ...,
use_global_cache: Incomplete | None = ...,
use_datastore: Incomplete | None = ...,
global_cache_timeout: Incomplete | None = ...,
use_memcache: Incomplete | None = ...,
memcache_timeout: Incomplete | None = ...,
max_memcache_items: Incomplete | None = ...,
force_writes: Incomplete | None = ...,
_options: Incomplete | None = ...,
read_consistency=None,
read_policy=None,
transaction=None,
retries=None,
timeout=None,
deadline=None,
use_cache=None,
use_global_cache=None,
use_datastore=None,
global_cache_timeout=None,
use_memcache=None,
memcache_timeout=None,
max_memcache_items=None,
force_writes=None,
_options=None,
): ...
def delete(
self,
retries: Incomplete | None = ...,
timeout: Incomplete | None = ...,
deadline: Incomplete | None = ...,
use_cache: Incomplete | None = ...,
use_global_cache: Incomplete | None = ...,
use_datastore: Incomplete | None = ...,
global_cache_timeout: Incomplete | None = ...,
use_memcache: Incomplete | None = ...,
memcache_timeout: Incomplete | None = ...,
max_memcache_items: Incomplete | None = ...,
force_writes: Incomplete | None = ...,
_options: Incomplete | None = ...,
retries=None,
timeout=None,
deadline=None,
use_cache=None,
use_global_cache=None,
use_datastore=None,
global_cache_timeout=None,
use_memcache=None,
memcache_timeout=None,
max_memcache_items=None,
force_writes=None,
_options=None,
): ...
def delete_async(
self,
retries: Incomplete | None = ...,
timeout: Incomplete | None = ...,
deadline: Incomplete | None = ...,
use_cache: Incomplete | None = ...,
use_global_cache: Incomplete | None = ...,
use_datastore: Incomplete | None = ...,
global_cache_timeout: Incomplete | None = ...,
use_memcache: Incomplete | None = ...,
memcache_timeout: Incomplete | None = ...,
max_memcache_items: Incomplete | None = ...,
force_writes: Incomplete | None = ...,
_options: Incomplete | None = ...,
retries=None,
timeout=None,
deadline=None,
use_cache=None,
use_global_cache=None,
use_datastore=None,
global_cache_timeout=None,
use_memcache=None,
memcache_timeout=None,
max_memcache_items=None,
force_writes=None,
_options=None,
): ...
@classmethod
def from_old_key(cls, old_key) -> None: ...
Expand Down
8 changes: 4 additions & 4 deletions stubs/google-cloud-ndb/google/cloud/ndb/metadata.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ class EntityGroup:
def __new__(cls, *args, **kwargs): ...

def get_entity_group_version(*args, **kwargs) -> None: ...
def get_kinds(start: Incomplete | None = ..., end: Incomplete | None = ...): ...
def get_namespaces(start: Incomplete | None = ..., end: Incomplete | None = ...): ...
def get_properties_of_kind(kind, start: Incomplete | None = ..., end: Incomplete | None = ...): ...
def get_representations_of_kind(kind, start: Incomplete | None = ..., end: Incomplete | None = ...): ...
def get_kinds(start=None, end=None): ...
def get_namespaces(start=None, end=None): ...
def get_properties_of_kind(kind, start=None, end=None): ...
def get_representations_of_kind(kind, start=None, end=None): ...
Loading
Loading