Method _async_transformer

python/pathway/internals/table.py:2847–2852

(self, context: clmn.AsyncTransformerContext)

    @contextualized_operator
    def _async_transformer(self, context: clmn.AsyncTransformerContext) -> Table:
        columns = {
            name: clmn.ColumnWithoutExpression(context, context.universe, dtype)
            for name, dtype in context.schema._dtypes().items()
        }
        return Table(_columns=columns, _context=context)

    @trace_user_frame
    @contextualized_operator