File tree Expand file tree Collapse file tree 4 files changed +16
-12
lines changed
src/frequenz/client/marketmetering Expand file tree Collapse file tree 4 files changed +16
-12
lines changed Original file line number Diff line number Diff line change @@ -7,7 +7,12 @@ Initial release of the Frequenz Market Metering API client for Python.
77## New Features
88
99- ` MarketMeteringApiClient ` : Main client class for connecting to the Market Metering service
10- - ` stream_samples() ` : Async iterator for streaming metering samples from Market Locations
10+ - ` upsert_samples() ` : Bidirectional streaming for upserting metering samples.
11+ - ` create_market_location() ` : Create a new Market Location.
12+ - ` update_market_location() ` : Update an existing Market Location.
13+ - ` activate_market_location() ` : Activate a Market Location.
14+ - ` deactivate_market_location() ` : Deactivate a Market Location.
15+ - ` list_market_locations() ` : List Market Locations with filtering and pagination.
1116- ` stream() ` : Channel-based receiver for streaming with automatic reconnection
1217- CLI tool (` marketmetering-cli ` ) for quick access to metering data
1318- Support for multiple market identifier types:
Original file line number Diff line number Diff line change @@ -102,9 +102,9 @@ plugins:
102102 - mkdocstrings :
103103 default_handler : python
104104 handlers :
105- paths : ["src"]
106105 python :
107106 options :
107+ paths : ["src"]
108108 docstring_section_style : spacy
109109 inherited_members : true
110110 merge_init_into_class : false
@@ -116,7 +116,7 @@ plugins:
116116 show_source : true
117117 show_symbol_type_toc : true
118118 signature_crossrefs : true
119- inventories :
119+ import :
120120 # TODO(cookiecutter): You might want to add other external references here
121121 # See https://mkdocstrings.github.io/python/usage/#import for details
122122 - https://docs.python.org/3/objects.inv
Original file line number Diff line number Diff line change 2929 MarketLocationsFilter ,
3030 MarketLocationUpdate ,
3131 MetricType ,
32- MetricUnit ,
3332 PaginationParams ,
3433 ResamplingOptions ,
3534 RevisionSelection ,
3635 UpsertResult ,
37- MarketLocationSample ,
3836)
3937
4038DEFAULT_PORT = 443
Original file line number Diff line number Diff line change 1212 pagination_params_pb2 as pagination_params_pb ,
1313)
1414from frequenz .api .marketmetering .v1alpha1 import marketmetering_pb2 as pb
15- from google .protobuf import struct_pb2
16- from google .protobuf import field_mask_pb2
15+ from google .protobuf import field_mask_pb2 , struct_pb2
1716from google .protobuf .timestamp_pb2 import Timestamp
1817
1918
@@ -691,11 +690,13 @@ def from_protobuf(
691690 # Here we assume it's always present or defaults to 0.
692691 revision = pb_obj .revision ,
693692 update_time = update_time ,
694- resampling_method = ResamplingMethod (pb_obj .resampling_method )
695- if isinstance (pb_obj , pb .MarketLocationSampleDetail )
696- # Fallback to UNSPECIFIED if it's a simple MarketLocationSample
697- # which does not have this field.
698- else ResamplingMethod .UNSPECIFIED ,
693+ resampling_method = (
694+ ResamplingMethod (pb_obj .resampling_method )
695+ if isinstance (pb_obj , pb .MarketLocationSampleDetail )
696+ # Fallback to UNSPECIFIED if it's a simple MarketLocationSample
697+ # which does not have this field.
698+ else ResamplingMethod .UNSPECIFIED
699+ ),
699700 )
700701
701702 def to_protobuf (self ) -> pb .MarketLocationSample :
You can’t perform that action at this time.
0 commit comments