actions: Use transaction.atomic in do_change_default_sending_stream.

This commit is contained in:
Sahil Batra
2022-01-03 15:46:25 +05:30
committed by Tim Abbott
parent cb43bdab93
commit c8f81ded4e

View File

@@ -4808,6 +4808,7 @@ def do_change_realm_plan_type(
send_event(realm, event, active_user_ids(realm.id)) send_event(realm, event, active_user_ids(realm.id))
@transaction.atomic(durable=True)
def do_change_default_sending_stream( def do_change_default_sending_stream(
user_profile: UserProfile, stream: Optional[Stream], *, acting_user: Optional[UserProfile] user_profile: UserProfile, stream: Optional[Stream], *, acting_user: Optional[UserProfile]
) -> None: ) -> None:
@@ -4835,17 +4836,20 @@ def do_change_default_sending_stream(
stream_name: Optional[str] = stream.name stream_name: Optional[str] = stream.name
else: else:
stream_name = None stream_name = None
send_event( event = dict(
user_profile.realm, type="realm_bot",
dict( op="update",
type="realm_bot", bot=dict(
op="update", user_id=user_profile.id,
bot=dict( default_sending_stream=stream_name,
user_id=user_profile.id,
default_sending_stream=stream_name,
),
), ),
bot_owner_user_ids(user_profile), )
transaction.on_commit(
lambda: send_event(
user_profile.realm,
event,
bot_owner_user_ids(user_profile),
)
) )