Skip to content

Commit

Permalink
chore: Fix fmt errors
Browse files Browse the repository at this point in the history
  • Loading branch information
bakjos committed Apr 2, 2024
1 parent bccc02e commit 4d75e6a
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
2 changes: 0 additions & 2 deletions ci/scripts/run-e2e-test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -71,8 +71,6 @@ download-and-decompress-artifact risingwave_e2e_extended_mode_test-"$profile" ta
mkdir -p e2e_test/udf/wasm/target/wasm32-wasi/release/
buildkite-agent artifact download udf.wasm e2e_test/udf/wasm/target/wasm32-wasi/release/
buildkite-agent artifact download risingwave-udf-example.jar ./
mkdir -p e2e_test/udf/sse/server/target/release/
buildkite-agent artifact download e2e_test/udf/sse/server/target/release/
mv target/debug/risingwave_e2e_extended_mode_test-"$profile" target/debug/risingwave_e2e_extended_mode_test

chmod +x ./target/debug/risingwave_e2e_extended_mode_test
Expand Down
4 changes: 2 additions & 2 deletions e2e_test/udf/sse/sse.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ def format_sse(data: str | None, event=None) -> str:
msg = f'data: {data}\n\n'
else:
msg = '\n'

if event is not None:
msg = f'event: {event}\n{msg}'

Expand All @@ -29,7 +29,7 @@ def eventStream():
}
}
yield format_sse(json.dumps(data), "next")

yield format_sse(None, "complete")
return Response(eventStream(), mimetype="text/event-stream")

Expand Down

0 comments on commit 4d75e6a

Please sign in to comment.