(
(let $1 (OptionalType (DataType 'Int32)))
(let $2 '('('"_logical_id" '4538) '('"_id" '"418e8811-8f7c34df-edbc03a7-fc24b7de") '('"_partition_mode" '"single")))
(let $3 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"a" (String '"foo")) '('"b" (SafeCast (String '"123") $1)))))) $2))
(let $4 (DqCnResult (TDqOutput $3 '"0") '()))
(return (KqpPhysicalQuery '((KqpPhysicalTx '($3) '($4) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"a" (DataType 'String)) '('"b" $1))) '"0" '"0")) '('('"type" '"query"))))
)
