Skip to content

Commit a3f68d6

Browse files
nit
1 parent 747f7e1 commit a3f68d6

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/replit_river/v2/session.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -791,12 +791,11 @@ async def send_upload[I, R, A](
791791
# If this request is not closed and the session is killed, we should
792792
# throw exception here
793793
async for item in request:
794-
control_flags = 0
795794
await self.send_message(
796795
stream_id=stream_id,
797796
service_name=service_name,
798797
procedure_name=procedure_name,
799-
control_flags=control_flags,
798+
control_flags=0,
800799
payload=request_serializer(item),
801800
span=span,
802801
)

0 commit comments

Comments
 (0)