Skip to content

Commit f58031d

Browse files
Completing LDM refactor
1 parent 3c63c45 commit f58031d

File tree

3 files changed

+8
-6
lines changed

3 files changed

+8
-6
lines changed

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
44

55
[project]
66
name = "v2xflexstack"
7-
version = "0.10.0"
7+
version = "0.10.1"
88
authors = [
99
{ name = "Jordi Marias-i-Parella", email = "[email protected]" },
1010
{ name = "Daniel Ulied Guevara", email = "[email protected]" },

src/flexstack/facilities/local_dynamic_map/ldm_classes.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1536,13 +1536,14 @@ class SubscribeDataobjectsReq:
15361536
multiplicity: int
15371537
order: tuple[OrderTupleValue, ...]
15381538

1539+
15391540
@dataclass(frozen=True)
15401541
class SubscriptionInfo:
15411542
"""
15421543
Non-standard class that represents Subscription Info for internal use.
15431544
"""
1544-
subscription_request : SubscribeDataobjectsReq
1545-
callback : Callable[[RequestDataObjectsResp], None]
1545+
subscription_request: SubscribeDataobjectsReq
1546+
callback: Callable[[RequestDataObjectsResp], None]
15461547

15471548

15481549
class SubscribeDataobjectsResult(IntEnum):

src/flexstack/facilities/local_dynamic_map/ldm_service.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,8 @@ def process_notifications(
155155
current_time = TimestampIts.initialize_with_utc_timestamp_seconds()
156156
notify_time = subscription.subscription_request.notify_time
157157
with self._lock:
158-
last_checked = self.last_checked_subscriptions_time.get(subscription)
158+
last_checked = self.last_checked_subscriptions_time.get(
159+
subscription)
159160
if last_checked is None:
160161
self.last_checked_subscriptions_time[subscription] = current_time
161162
last_checked = current_time
@@ -245,8 +246,8 @@ def build_key(item):
245246
for order in orders
246247
)
247248

248-
reverse = any(order.ordering_direction ==
249-
OrderingDirection.DESCENDING for order in orders)
249+
reverse = any(order.ordering_direction == OrderingDirection.DESCENDING
250+
for order in orders)
250251
return (tuple(sorted(search_results, key=build_key, reverse=reverse)),)
251252

252253
def add_provider_data(self, data: AddDataProviderReq) -> int | None:

0 commit comments

Comments
 (0)