Fixed Tests Issues

src/HotChocolate/Core/src/Execution/Instrumentation/AggregateExecutionDiagnosticEvents.cs

@@ -144,13 +144,13 @@ public IDisposable ExecuteOperation(IRequestContext context)
         return new AggregateActivityScope(scopes);
     }
 
-    public IDisposable ExecuteStream(IRequestContext context)
+    public IDisposable ExecuteStream(IOperation operation)
     {
         var scopes = new IDisposable[_listeners.Length];
 
         for (var i = 0; i < _listeners.Length; i++)
         {
-            scopes[i] = _listeners[i].ExecuteStream(context);
+            scopes[i] = _listeners[i].ExecuteStream(operation);
         }
 
         return new AggregateActivityScope(scopes);

src/HotChocolate/Core/src/Execution/Instrumentation/ExecutionDiagnosticEventListener.cs

@@ -82,7 +82,7 @@ public virtual IDisposable ExecuteOperation(IRequestContext context)
         => EmptyScope;
 
     /// <inheritdoc />
-    public virtual IDisposable ExecuteStream(IRequestContext context)
+    public virtual IDisposable ExecuteStream(IOperation operation)
         => EmptyScope;
 
     public virtual IDisposable ExecuteDeferredTask()

src/HotChocolate/Core/src/Execution/Instrumentation/IExecutionDiagnosticEvents.cs

@@ -163,16 +163,14 @@ public interface IExecutionDiagnosticEvents
     /// The ExecuteStream scope will run longer then the ExecuteOperation scope.
     /// The ExecuteOperation scope is completed once the initial operation is executed.
     /// All deferred elements will be executed and delivered within the ExecuteStream scope.
-    /// The passed in context is polled and can only be used at the initialization of the scope.
     /// </summary>
-    /// <param name="context">
-    /// The request context encapsulates all GraphQL-specific information about an
-    /// individual GraphQL request.
+    /// <param name="operation">
+    /// The operation that is being streamed.
     /// </param>
     /// <returns>
     /// A scope that will be disposed when the execution has finished.
     /// </returns>
-    IDisposable ExecuteStream(IRequestContext context);
+    IDisposable ExecuteStream(IOperation operation);
 
     /// <summary>
     /// Called when starting to execute a deferred part an operation

src/HotChocolate/Core/src/Execution/Instrumentation/NoopExecutionDiagnosticEvents.cs

@@ -44,11 +44,9 @@ public void OperationComplexityResult(
 
     public IDisposable CompileOperation(IRequestContext context) => this;
 
-    public IDisposable BuildQueryPlan(IRequestContext context) => this;
-
     public IDisposable ExecuteOperation(IRequestContext context) => this;
 
-    public IDisposable ExecuteStream(IRequestContext context) => this;
+    public IDisposable ExecuteStream(IOperation operation) => this;
 
     public IDisposable ExecuteDeferredTask() => this;
 

src/HotChocolate/Core/src/Execution/Processing/DeferredWorkScheduler.cs

@@ -1,6 +1,8 @@
+using System;
 using System.Collections.Generic;
 using System.Threading;
 using HotChocolate.Execution.DependencyInjection;
+using HotChocolate.Execution.Instrumentation;
 using static HotChocolate.Execution.QueryResultBuilder;
 
 namespace HotChocolate.Execution.Processing;
@@ -64,22 +66,36 @@ public void Complete(DeferredExecutionTaskResult result)
         => StateOwner.State.Complete(result);
 
     public IAsyncEnumerable<IQueryResult> CreateResultStream(IQueryResult initialResult)
-        => new DeferResultStream(initialResult, StateOwner);
+        => new DeferResultStream(
+            initialResult,
+            StateOwner,
+            _parentContext.Operation,
+            _parentContext.DiagnosticEvents);
 
     private class DeferResultStream : IAsyncEnumerable<IQueryResult>
     {
         private readonly IQueryResult _initialResult;
         private readonly DeferredWorkStateOwner _stateOwner;
-
-        public DeferResultStream(IQueryResult initialResult, DeferredWorkStateOwner stateOwner)
+        private readonly IOperation _operation;
+        private readonly IExecutionDiagnosticEvents _diagnosticEvents;
+
+        public DeferResultStream(
+            IQueryResult initialResult,
+            DeferredWorkStateOwner stateOwner,
+            IOperation operation,
+            IExecutionDiagnosticEvents diagnosticEvents)
         {
             _initialResult = FromResult(initialResult).SetHasNext(true).Create();
             _stateOwner = stateOwner;
+            _operation = operation;
+            _diagnosticEvents = diagnosticEvents;
         }
 
         public async IAsyncEnumerator<IQueryResult> GetAsyncEnumerator(
             CancellationToken cancellationToken = default)
         {
+            var span = _diagnosticEvents.ExecuteStream(_operation);
+
             try
             {
 
@@ -102,6 +118,7 @@ public async IAsyncEnumerator<IQueryResult> GetAsyncEnumerator(
             finally
             {
                 _stateOwner.Dispose();
+                span.Dispose();
             }
         }
     }

src/HotChocolate/Core/src/Execution/Processing/Tasks/ResolverTaskFactory.cs

@@ -20,8 +20,8 @@ public static ObjectResult EnqueueResolverTasks(
         Path path,
         IImmutableDictionary<string, object?> scopedContext)
     {
-        var responseIndex = 0;
         var selectionsCount = selectionSet.Selections.Count;
+        var responseIndex = selectionsCount;
         var parentResult = operationContext.Result.RentObject(selectionsCount);
         var scheduler = operationContext.Scheduler;
         var pathFactory = operationContext.PathFactory;
@@ -35,7 +35,13 @@ public static ObjectResult EnqueueResolverTasks(
         {
             ref var selectionSpace = ref ((SelectionSet)selectionSet).GetSelectionsReference();
 
-            for (var i = 0; i < selectionsCount; i++)
+            // we are iterating reverse so that in the case of a mutation the first
+            // synchronous root selection is executed first, since the work scheduler
+            // is using two stacks one for parallel work an one for synchronous work.
+            // the scheduler this tries to schedule new work first.
+            // coincidentally we can use that to schedule a mutation so that we honor the spec
+            // guarantees while executing efficient.
+            for (var i = selectionsCount - 1; i >= 0; i--)
             {
                 ref var selection = ref Unsafe.Add(ref selectionSpace, i);
 
@@ -46,7 +52,7 @@ public static ObjectResult EnqueueResolverTasks(
                             selection,
                             parent,
                             parentResult,
-                            responseIndex++,
+                            --responseIndex,
                             pathFactory.Append(path, selection.ResponseName),
                             scopedContext));
                 }

src/HotChocolate/Data/test/Data.AutoMapper.Tests/AutomapperTests.cs

@@ -95,11 +95,11 @@ public class ProjectToTests
     public async Task Execute_ManyToOne()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -121,11 +121,11 @@ public async Task Execute_ManyToOne()
     public async Task Execute_ManyToOne_Deep()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -156,11 +156,11 @@ query Test {
     public async Task Execute_OneToOne()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -181,11 +181,11 @@ public async Task Execute_OneToOne()
     public async Task Execute_OneToOne_Deep()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -210,11 +210,11 @@ query Test {
     public async Task Execute_Derived_CompleteSelectionSet()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -234,11 +234,11 @@ ... on StandardMemberDto { standard }
     public async Task Execute_Derived_PartialSelectionSet()
     {
         // arrange
-        IRequestExecutor tester = await CreateSchema();
+        var tester = await CreateSchema();
 
         // act
         // assert
-        IExecutionResult res1 = await tester.ExecuteAsync(
+        var res1 = await tester.ExecuteAsync(
             QueryRequestBuilder.New()
                 .SetQuery(
                     @"
@@ -267,11 +267,11 @@ public async ValueTask<IRequestExecutor> CreateSchema()
             mc.AddProfile(new AuthorProfile());
         });
 
-        IMapper mapper = mapperConfig.CreateMapper();
+        var mapper = mapperConfig.CreateMapper();
         services.AddSingleton(sp =>
         {
             // abusing the mapper factory to add to the database. You didnt see this.
-            BloggingContext context =
+            var context =
                 sp.GetRequiredService<IDbContextFactory<BloggingContext>>().CreateDbContext();
             context.Database.EnsureCreated();
             context.Blogs.AddRange(_blogEntries);

src/HotChocolate/Data/test/Data.EntityFramework.Tests/AuthorFixture.cs

@@ -30,7 +30,7 @@ public class AuthorFixture : IDisposable
     public AuthorFixture()
     {
         _fileName = Guid.NewGuid().ToString("N") + ".db";
-        BookContext context = new ServiceCollection()
+        var context = new ServiceCollection()
             .AddDbContext<BookContext>(
                 b => b.UseSqlite("Data Source=" + _fileName))
             .AddGraphQL()

src/HotChocolate/Data/test/Data.EntityFramework.Tests/EntityFrameworkExecutableTests.cs

@@ -20,7 +20,7 @@ public void Extensions_Should_ReturnEntityFrameworkExecutable_When_DBSet()
     {
         // arrange
         // act
-        IExecutable<Author> executable = _context.Authors.AsExecutable();
+        var executable = _context.Authors.AsExecutable();
 
         // assert
         Assert.IsType<EntityFrameworkExecutable<Author>>(executable);
@@ -32,7 +32,7 @@ public void Extensions_Should_ReturnEntityFrameworkExecutable_When_Queryable()
     {
         // arrange
         // act
-        IExecutable<Author> executable = _context
+        var executable = _context
             .Authors
             .AsQueryable()
             .AsEntityFrameworkExecutable();
@@ -47,7 +47,7 @@ public void Extensions_Should_ReturnEntityFrameworkExecutable_When_Queryable()
     public async Task ExecuteAsync_Should_ReturnAllItems_When_ToListAsync()
     {
         // arrange
-        IExecutable<Author> executable = _context
+        var executable = _context
             .Authors
             .AsExecutable();
 

src/HotChocolate/Data/test/Data.EntityFramework.Tests/EntityFrameworkResolverCompilerIntegrationTests.cs

@@ -48,7 +48,7 @@ public async Task Resolver_Pipeline_With_Request_DbContext_Is_Created()
 
         using AuthorFixture authorFixture = new();
 
-        using IServiceScope scope = new ServiceCollection()
+        using var scope = new ServiceCollection()
             .AddScoped(_ => authorFixture.Context)
             .AddGraphQL()
             .AddQueryType<Query>()
@@ -58,7 +58,7 @@ public async Task Resolver_Pipeline_With_Request_DbContext_Is_Created()
             .BuildServiceProvider()
             .CreateScope();
 
-        IExecutionResult result = await scope.ServiceProvider.ExecuteRequestAsync(
+        var result = await scope.ServiceProvider.ExecuteRequestAsync(
             QueryRequestBuilder.New()
                 .SetQuery("{ books { title } }")
                 .SetServices(scope.ServiceProvider)
@@ -74,7 +74,7 @@ public async Task Resolver_Pipeline_With_Field_DbContext_Is_Created()
 
         using AuthorFixture authorFixture = new();
 
-        await using ServiceProvider service = new ServiceCollection()
+        await using var service = new ServiceCollection()
             .AddScoped(_ => authorFixture.Context)
             .AddGraphQL()
             .AddQueryType<Query>()