emcake

/*
To replicate:

type SuperArrow<'a, 'b> = 
    | Fn of (('a -> 'b) * string)
    | Compose of SuperArrowCompose<'a,'b>
and SuperArrowCompose<'a,'b> = 
    abstract member eval : SuperArrowComposeEvaluator<'a, 'b, 'r> -> 'r
and SuperArrowComposeEvaluator<'a, 'b, 'r> = 
    abstract member apply<'c> : SuperArrow<'a, 'c> -> SuperArrow<'c, 'b> -> 'r

emcake

type ListBuilder() =
    
    /// map
    member x.For(l,f) = 
        List.map f l

    /// id
    member x.Yield(v) = 
        v

emcake

using System;

interface Generator<A,Y,R>
    where Y : struct
    where R : struct
{
    unsafe bool Resume(A a, System.Span<Y> y, System.Span<R> r);
}

struct None {

emcake

import prefect
from prefect import Flow, task, Task, case, Parameter
from prefect.environments import LocalEnvironment
from prefect.environments.storage import S3
from prefect.tasks.prefect import FlowRunTask
from prefect.tasks.control_flow import merge
from prefect.engine.results import PrefectResult


@task

emcake

import prefect
from prefect import Flow, task, Task, case, Parameter
from prefect.environments import LocalEnvironment
from prefect.environments.storage import S3
from prefect.tasks.prefect import FlowRunTask
from prefect.tasks.control_flow import merge
from prefect.engine.results import PrefectResult

with Flow('subflow-one') as subflow_one:
    x = Parameter('x')

emcake

emcake

from deltalake import DeltaTable, write_deltalake
import pandas as pd


delta_path = f"/tmp/table-conflict-test"
print(delta_path)

write_deltalake(
    delta_path,
    pd.DataFrame.from_dict(