Skip to content

Commit afbc846

Browse files
committed
support full delta operation generation for factdb
1 parent 631dca7 commit afbc846

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

horizon/data_manager/policy_store.py

+16
Original file line numberDiff line numberDiff line change
@@ -79,14 +79,30 @@ def _generate_operations(
7979
self, parts: list[str], data: JsonableValue
8080
) -> Iterator[AnyOperation]:
8181
match parts:
82+
case ["relationships"]:
83+
for obj, _data in data.items():
84+
yield from _get_operations_for_update_relationship_tuple(obj, _data)
8285
case ["relationships", obj]:
8386
yield from _get_operations_for_update_relationship_tuple(obj, data)
87+
case ["role_assignments"]:
88+
for full_user_key, _data in data.items():
89+
yield from _get_operations_for_update_role_assigment(
90+
full_user_key, _data
91+
)
8492
case ["role_assignments", full_user_key]:
8593
yield from _get_operations_for_update_role_assigment(
8694
full_user_key, data
8795
)
96+
case ["users"]:
97+
for user_key, _data in data.items():
98+
yield from _get_operations_for_update_user(user_key, _data)
8899
case ["users", user_key]:
89100
yield from _get_operations_for_update_user(user_key, data)
101+
case ["resource_instances"]:
102+
for instance_key, _data in data.items():
103+
yield from _get_operations_for_update_resource_instance(
104+
instance_key, _data
105+
)
90106
case ["resource_instances", instance_key]:
91107
yield from _get_operations_for_update_resource_instance(
92108
instance_key, data

0 commit comments

Comments
 (0)