MCPcopy
hub / github.com/faust-streaming/faust / update

Method update

faust/types/serializers.py:85–93  ·  view source on GitHub ↗
(
        self,
        *,
        key_type: _ModelArg = None,
        value_type: _ModelArg = None,
        key_serializer: CodecArg = None,
        value_serializer: CodecArg = None,
        allow_empty: Optional[bool] = None,
    )

Source from the content-addressed store, hash-verified

83
84 @abc.abstractmethod
85 def update(
86 self,
87 *,
88 key_type: _ModelArg = None,
89 value_type: _ModelArg = None,
90 key_serializer: CodecArg = None,
91 value_serializer: CodecArg = None,
92 allow_empty: Optional[bool] = None,
93 ) -> None: ...
94
95 @abc.abstractmethod
96 def loads_key(

Callers 15

setup.pyFile · 0.45
find_settings_in_rstFunction · 0.45
test_updateMethod · 0.45
test__get__has_event_value_diff_partitionMethod · 0.45
test_get_bucket_for_key__not_in_indexMethod · 0.45
test__contains__has_event_value_diff_partitionMethod · 0.45
test_perform_seekMethod · 0.45
test_commit_offsetsMethod · 0.45
test_commit_offsets__did_not_commitMethod · 0.45
test_commit_offsets__in_transactionMethod · 0.45
test_on_change__diffMethod · 0.45
test_on_change__updateMethod · 0.45

Calls

no outgoing calls

Tested by 15

test_updateMethod · 0.36
test__get__has_event_value_diff_partitionMethod · 0.36
test_get_bucket_for_key__not_in_indexMethod · 0.36
test__contains__has_event_value_diff_partitionMethod · 0.36
test_perform_seekMethod · 0.36
test_commit_offsetsMethod · 0.36
test_commit_offsets__did_not_commitMethod · 0.36
test_commit_offsets__in_transactionMethod · 0.36
test_on_change__diffMethod · 0.36
test_on_change__updateMethod · 0.36
test_sync_from_storageMethod · 0.36
test_as_stored_valueMethod · 0.36