use plato;

pragma Engine = "ytflow";

pragma Ytflow.Cluster = "plato";
pragma Ytflow.PipelinePath = "pipelines/test";

insert into Output
select 
    FromMutDict(FromDynamicLinear(Unwrap(Opaque([
        ToDynamicLinear(ToMutDict({string_field: int64_field}, 1))
    ])[0]))) as dict_field
from Input;