Skip to content

Commit aa07878

Browse files
committed
handle_command no longer returns
1 parent 0f592fe commit aa07878

File tree

2 files changed

+3
-8
lines changed

2 files changed

+3
-8
lines changed

src/allocation/entrypoints/flask_app.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,7 @@ def allocate_endpoint():
3131
request.json['orderid'], request.json['sku'], request.json['qty'],
3232
)
3333
uow = unit_of_work.SqlAlchemyUnitOfWork()
34-
results = messagebus.handle(cmd, uow)
35-
batchref = results.pop(0)
34+
messagebus.handle(cmd, uow)
3635
except InvalidSku as e:
3736
return jsonify({'message': str(e)}), 400
3837

src/allocation/service_layer/messagebus.py

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -14,18 +14,15 @@
1414

1515

1616
def handle(message: Message, uow: unit_of_work.AbstractUnitOfWork):
17-
results = []
1817
queue = [message]
1918
while queue:
2019
message = queue.pop(0)
2120
if isinstance(message, events.Event):
2221
handle_event(message, queue, uow)
2322
elif isinstance(message, commands.Command):
24-
cmd_result = handle_command(message, queue, uow)
25-
results.append(cmd_result)
23+
handle_command(message, queue, uow)
2624
else:
2725
raise Exception(f'{message} was not an Event or Command')
28-
return results
2926

3027

3128
def handle_event(
@@ -51,9 +48,8 @@ def handle_command(
5148
logger.debug('handling command %s', command)
5249
try:
5350
handler = COMMAND_HANDLERS[type(command)]
54-
result = handler(command, uow=uow)
51+
handler(command, uow=uow)
5552
queue.extend(uow.collect_new_events())
56-
return result
5753
except Exception:
5854
logger.exception('Exception handling command %s', command)
5955
raise

0 commit comments

Comments
 (0)