Fix integratino tests

This commit is contained in:
Cyber MacGeddon 2025-12-18 07:33:56 +00:00
parent 232c6ccebb
commit fe49a606cf

View file

@ -342,7 +342,7 @@ async def test_websocket_close_during_message_processing():
import_handler = TriplesImport( import_handler = TriplesImport(
ws=ws, ws=ws,
running=running, running=running,
backend=mock_backend, backend=mock_backend_local,
queue="slow-processing-import" queue="slow-processing-import"
) )
@ -406,8 +406,8 @@ async def test_backpressure_during_shutdown():
export_handler = TriplesExport( export_handler = TriplesExport(
ws=ws, ws=ws,
running=running, running=running,
backend=mock_backend, backend=mock_backend_local,
queue="backpressure-export", queue="backpressure-export",
consumer="backpressure-consumer", consumer="backpressure-consumer",
subscriber="backpressure-subscriber" subscriber="backpressure-subscriber"