In order to support aio blob client types, the decode() method needs to be async. This is currently not supported, because the from_incoming_proto() method in the worker, where decode() is called, is a sync call.
This changes from_incoming_proto() to be an async method instead.
Tests are added for the new async blob client types to test this change. These new tests will fail until a new blob extension version with the aio types is released.
Fixes #
PR information
[ ] The title of the PR is clear and informative.
[ ] There are a small number of commits, each of which has an informative message. This means that previously merged commits do not appear in the history of the PR. For information on cleaning up the commits in your pull request, see this page.
[ ] If applicable, the PR references the bug/issue that it fixes in the description.
[ ] New Unit tests were added for the changes made and CI is passing.
Description
In order to support aio blob client types, the
decode()method needs to be async. This is currently not supported, because thefrom_incoming_proto()method in the worker, wheredecode()is called, is a sync call.This changes
from_incoming_proto()to be an async method instead.Tests are added for the new async blob client types to test this change. These new tests will fail until a new blob extension version with the aio types is released.
Fixes #
PR information
Quality of Code and Contribution Guidelines