EventHandler.fs

// DEFINE PROCESSOR

type MyEventProcessorClient<'a>(blobContainer:BlobContainerClient,consumerGroup:string,connectionString:string,eventHubName:string,logger : ILogger<'a>,partitionID:string) =
    inherit EventProcessorClient(blobContainer,consumerGroup,connectionString,eventHubName)

    override __.ClaimOwnershipAsync(partitions:System.Collections.Generic.IEnumerable<_>, token:CancellationToken) = task {
        return partitions |> Seq.filter (fun p -> p.PartitionId = partitionID)
    }



// USAGE

let processor =
    new MyEventProcessorClient<Worker>(
        blobContainer,
        consumerGroup,
        eventHubsConnectionKey.Force(),
        "myevents",
        _logger,
        string partition)

processor.add_ProcessEventAsync(fun args ->
    task {
        let text = Encoding.UTF8.GetString(args.Data.EventBody.ToArray())

        let message = Newtonsoft.Json.JsonConvert.DeserializeObject<MyEvent> text
        _logger.LogInformation($"Partition: {partition} {args.Data.PartitionKey}")
        try
            do! EventHandler.run _logger message
        with
        | exn -> _logger.LogInformation($"Error: {exn.Message}")
        do! args.UpdateCheckpointAsync(stoppingToken)
    }
    :> Task
)
processor.add_ProcessErrorAsync(fun args ->
    task {
        _logger.LogInformation($"ProcessError: {args.Exception.Message}")
    } :> Task
)

That looks about right to me.