Syncify

Package: flyte.syncify

A decorator to convert asynchronous functions or methods into synchronous ones.

This is useful for integrating async code into synchronous contexts.

syncer = Syncify()

@syncer
async def async_function(x: str) -> str:
    return f"Hello, Async World {x}!"


# now you can call it synchronously
result = async_function("Async World")
print(result)
# Output: Hello, Async World Async World!

# or call it asynchronously
async def main():
    result = await async_function.aio("World")
    print(result)

Parameters

class Syncify(
    name: str = 'flyte_syncify',
)

Methods

awaitable_compat()

def awaitable_compat(
    func: Callable[P, Awaitable[R_co]],
) -> SyncFunction[P, R_co]

Like the Syncify decorator, for an async method that callers used to await directly.

Called with no running event loop in the current thread, it runs synchronously and returns the result, the same as a syncified method. Called inside a running event loop, it returns the coroutine so that legacy await obj.method() code keeps working, and emits a DeprecationWarning once per call site recommending await obj.method.aio(), which is the preferred async form and behaves as it does with Syncify.

Only plain async functions and instance methods are supported.