@@ -1069,7 +1069,7 @@ def _deserialize_link(self, doc: JourneyLinkAssociationDocument) -> JourneyLink:
10691069 merge_node_id = JourneyNodeId (doc ["merge_node_id" ]),
10701070 )
10711071
1072- async def _touch_journey_last_modified (self , journey_id : JourneyId ) -> None :
1072+ async def _update_journey_last_modified (self , journey_id : JourneyId ) -> None :
10731073 """Update the journey's last_modified timestamp."""
10741074 await self ._collection .update_one (
10751075 filters = {"id" : {"$eq" : journey_id }},
@@ -1526,7 +1526,7 @@ async def create_node(
15261526 document = self ._serialize_node (node , journey_id )
15271527 )
15281528
1529- await self ._touch_journey_last_modified (journey_id )
1529+ await self ._update_journey_last_modified (journey_id )
15301530
15311531 return node
15321532
@@ -1575,7 +1575,7 @@ async def update_node(
15751575 params = cast (JourneyNodeAssociationDocument , to_json_dict (updated )),
15761576 )
15771577
1578- await self ._touch_journey_last_modified (doc ["journey_id" ])
1578+ await self ._update_journey_last_modified (doc ["journey_id" ])
15791579
15801580 assert result .updated_document
15811581
@@ -1605,7 +1605,7 @@ async def delete_node(
16051605 filters = {"node_id" : {"$eq" : node_id }}
16061606 )
16071607
1608- await self ._touch_journey_last_modified (journey_id )
1608+ await self ._update_journey_last_modified (journey_id )
16091609
16101610 if result .deleted_count == 0 :
16111611 raise ItemNotFoundError (item_id = UniqueId (node_id ))
@@ -1789,7 +1789,7 @@ async def create_edge(
17891789 document = self ._serialize_edge (edge , journey_id )
17901790 )
17911791
1792- await self ._touch_journey_last_modified (journey_id )
1792+ await self ._update_journey_last_modified (journey_id )
17931793
17941794 return edge
17951795
@@ -1825,7 +1825,7 @@ async def update_edge(
18251825 params = cast (JourneyEdgeAssociationDocument , to_json_dict (updated )),
18261826 )
18271827
1828- await self ._touch_journey_last_modified (doc ["journey_id" ])
1828+ await self ._update_journey_last_modified (doc ["journey_id" ])
18291829
18301830 assert result .updated_document
18311831
@@ -1871,7 +1871,7 @@ async def delete_edge(
18711871 )
18721872
18731873 if result .deleted_count > 0 and edge_doc :
1874- await self ._touch_journey_last_modified (edge_doc ["journey_id" ])
1874+ await self ._update_journey_last_modified (edge_doc ["journey_id" ])
18751875
18761876 if result .deleted_count == 0 :
18771877 raise ItemNotFoundError (item_id = UniqueId (edge_id ))
@@ -2066,7 +2066,7 @@ async def create_link(
20662066
20672067 async with self ._lock .writer_lock :
20682068 await self ._link_association_collection .insert_one (document = self ._serialize_link (link ))
2069- await self ._touch_journey_last_modified (journey_id )
2069+ await self ._update_journey_last_modified (journey_id )
20702070
20712071 return link
20722072
0 commit comments