diff --git a/astacus/coordinator/cluster.py b/astacus/coordinator/cluster.py index 952f9d99..fa5f15a0 100644 --- a/astacus/coordinator/cluster.py +++ b/astacus/coordinator/cluster.py @@ -111,7 +111,9 @@ async def request_from_nodes( # Now 'reqs' + 'urls' contains all we need to actually perform # requests we want to. - aws = [utils.httpx_request(url, caller=caller, data=msgspec.json.encode(req), **kw) for req, url in zip(reqs, urls)] + aws = [ + utils.httpx_request(url, caller=caller, content=msgspec.json.encode(req), **kw) for req, url in zip(reqs, urls) + ] results = await asyncio.gather(*aws, return_exceptions=True) logger.info("request_from_nodes %r to %r => %r", reqs, urls, results)