Question about activity durations on Gantt charts

[scale-tone]

Btw I have a question for you: I've noticed that the total run time for each activity on the Gantt chart is a sum of "waiting time" with "execution" time. Is there a way for you to show those timings separately?

I say that because on the servers I have a 10 minute limit, and I can see some taking 20 min. So, I suppose this is the sum of waiting time (scheduled) with actual execution time.

Originally posted by @junalmeida in #22 (comment)

[scale-tone]

@junalmeida, Gantt charts are generated out of data that DurableClient.GetStatusAsync() returns as execution history. Items in that array have two DateTime fields - Timestamp and ScheduledTime. Line on a Gantt chart represents the difference between these two.

If I read the code and the data correctly, then yes, ScheduledTime is the time when an activity invocation message was sent and Timestamp is the moment when the activity result message was sent.

Yes, there're some other timestamps stored in the XXXHistory table, which we could potentially use to make Gantt charts more meaningful. Problem is that there're no documentation on those, so we can only make assumptions on their exact meaning.

Would it be possible for you to provide a couple of examples of those lengthy activities, as they appear in your XXXHistory table? Some 'TaskScheduled' event (with all its timestamps) + some corresponding 'TaskCompleted' event (also with all its timestamps) - and how this activity appears on the 'Details' page and on the Gantt chart?

[junalmeida]

This is what I see. Let me know if the query itself looks right.

The eventId 72 (20m37s):

The eventId 68 (20m42s):

[scale-tone]

Thanks for that info, @junalmeida .
As we can see from your timestamps, these activities indeed took ~20 min to execute, and no indication of any "waiting time" or anything similar. So I don't see any way to make the Gantt chart look more informative in this case.

But you mentioned that "10 minute limit" - what is that? Is that the functionTimeout setting that you've set to 10 minutes? Or how exactly are you configuring that (there were in fact lots of older ways to configure function execution timeouts, and most of them do not work anymore)?

[junalmeida]

This function lives on the basic serverless consumption plan, which implies on a 10 limit execution. Anything beyond that throws FunctionTimeoutException.

That's why I don't think that 20 minute report is real, and to add, I also can't find any function reporting more than 10 min on application insights.

I can try to find this exact instance for you.

[scale-tone]

@junalmeida , the default timeout for Consumption plan is 5 minutes, not 10. This is why I was asking whether (and how) you're configuring a custom value for that timeout. 10 minutes is the maximum allowed value for that config setting.

When your activity exceeds that timeout (either default or explicitly configured), it indeed is supposed to end up with a FunctionTimeoutException, like this:

And it should be shown as failed (in red) on the Gantt chart.

How many instances like this do you have? Is it just one instance or many?

Are you sure this instance was actually run in Azure? Could it somehow happen that it was run on some devbox or any third-party machine (e.g. if your cloud environment and your devbox occasionally share the same Storage and the same TaskHub)?

[junalmeida]

It is configured for 10 on its host.json file

And I can see a handful of activities shown as ran by more than 10 minutes on Gantt chart.

And no, I do not share Dev execution env on prod taskhub

[scale-tone]

By far I'm unable to reproduce the behavior you described.

Can you elaborate on what platform/language/Functions version you're using?

[scale-tone]

Also, can you check that your instance is healthy by itself? Aka that there're no host crashes due to e.g. OutOfMemoryException and no any other weird effects?

[junalmeida]

This project is written on C#, .NET Core 3.1. Az Functions v3.0.13, Durable Functions v2.5.1

Instance is healthy, I have no complaints and all jobs seem to be working. I can see no OOM on App Insights.

Also checking reports on performance, the worst call I have on past 24 hours is 7 min which is valid within the 10 min limit.

A peek of host.json

[scale-tone]

OK, after switching Microsoft.Azure.WebJobs.Extensions.DurableTask from v2.1.1 to v2.5.1 I can confirm that I can reproduce it.
In my case it looks like this:

Aka seems like some of those parallel activities are being queued and picked up for execution only after some other are finished. Even though this isn't being indicated by their ScheduledTime values.

Will try to play with it a little more. E.g. will try the latest version (since there's a slim hope that this weird behavior was fixed with this commit or any other commit).

In the meanwhile, since it is definitely not a DfMon bug, can I ask you to raise an issue in azure-functions-durable-extension ?

[scale-tone]

I can confirm that the behavior is the same with latest v2.6.1.

But I can also confirm, that this behavior only takes place, when the activity method is synchronous (aka if it holds a thread).

If the method is asynchronous (e.g. marked with async keyword and is implemented accordingly), all its executions are cancelled correctly, after 10 minutes, resulting in TimeoutExceptions as expected.

So I suggest that you check that your activity methods are implemented as asynchronous (returning Tasks), since it is a best practice anyway, especially for methods that can take that long to execute.

[junalmeida]

I do not have any activity which is not async. All return Task.
IMO I believe this happens when the server is busy enough to not start an activity immediately after scheduled. But if they do not record the actual execution start time, then indeed it is a bug to durable extension itself. I'm just not sure how to explain that properly as I don't know all the inner workings of durable extension.

[scale-tone]

I do not have any activity which is not async. All return Task

But can it happen that they still hold a thread inside of them (by e.g. doing a Thread.Sleep() or something similar) ?