@@ -98,7 +98,7 @@ public void Run(Pipelines.AgentJobRequestMessage jobRequestMessage, bool runOnce
98
98
Guid dispatchedJobId = _jobDispatchedQueue . Dequeue ( ) ;
99
99
if ( _jobInfos . TryGetValue ( dispatchedJobId , out currentDispatch ) )
100
100
{
101
- Trace . Verbose ( $ "Retrive previous WorkerDispather for job { currentDispatch . JobId } .") ;
101
+ Trace . Verbose ( $ "Retrive previous WorkerDispatcher for job { currentDispatch . JobId } .") ;
102
102
}
103
103
}
104
104
@@ -162,12 +162,12 @@ public async Task WaitAsync(CancellationToken token)
162
162
dispatchedJobId = _jobDispatchedQueue . Dequeue ( ) ;
163
163
if ( _jobInfos . TryGetValue ( dispatchedJobId , out currentDispatch ) )
164
164
{
165
- Trace . Verbose ( $ "Retrive previous WorkerDispather for job { currentDispatch . JobId } .") ;
165
+ Trace . Verbose ( $ "Retrive previous WorkerDispatcher for job { currentDispatch . JobId } .") ;
166
166
}
167
167
}
168
168
else
169
169
{
170
- Trace . Verbose ( $ "There is no running WorkerDispather needs to await.") ;
170
+ Trace . Verbose ( $ "There is no running WorkerDispatcher needs to await.") ;
171
171
}
172
172
173
173
if ( currentDispatch != null )
@@ -176,7 +176,7 @@ public async Task WaitAsync(CancellationToken token)
176
176
{
177
177
try
178
178
{
179
- Trace . Info ( $ "Waiting WorkerDispather for job { currentDispatch . JobId } run to finish.") ;
179
+ Trace . Info ( $ "Waiting WorkerDispatcher for job { currentDispatch . JobId } run to finish.") ;
180
180
await currentDispatch . WorkerDispatch ;
181
181
Trace . Info ( $ "Job request { currentDispatch . JobId } processed succeed.") ;
182
182
}
@@ -190,7 +190,7 @@ public async Task WaitAsync(CancellationToken token)
190
190
WorkerDispatcher workerDispatcher ;
191
191
if ( _jobInfos . TryRemove ( currentDispatch . JobId , out workerDispatcher ) )
192
192
{
193
- Trace . Verbose ( $ "Remove WorkerDispather from { nameof ( _jobInfos ) } dictionary for job { currentDispatch . JobId } .") ;
193
+ Trace . Verbose ( $ "Remove WorkerDispatcher from { nameof ( _jobInfos ) } dictionary for job { currentDispatch . JobId } .") ;
194
194
workerDispatcher . Dispose ( ) ;
195
195
}
196
196
}
@@ -209,7 +209,7 @@ public async Task ShutdownAsync()
209
209
{
210
210
try
211
211
{
212
- Trace . Info ( $ "Ensure WorkerDispather for job { currentDispatch . JobId } run to finish, cancel any running job.") ;
212
+ Trace . Info ( $ "Ensure WorkerDispatcher for job { currentDispatch . JobId } run to finish, cancel any running job.") ;
213
213
await EnsureDispatchFinished ( currentDispatch , cancelRunningJob : true ) ;
214
214
}
215
215
catch ( Exception ex )
@@ -222,7 +222,7 @@ public async Task ShutdownAsync()
222
222
WorkerDispatcher workerDispatcher ;
223
223
if ( _jobInfos . TryRemove ( currentDispatch . JobId , out workerDispatcher ) )
224
224
{
225
- Trace . Verbose ( $ "Remove WorkerDispather from { nameof ( _jobInfos ) } dictionary for job { currentDispatch . JobId } .") ;
225
+ Trace . Verbose ( $ "Remove WorkerDispatcher from { nameof ( _jobInfos ) } dictionary for job { currentDispatch . JobId } .") ;
226
226
workerDispatcher . Dispose ( ) ;
227
227
}
228
228
}
@@ -327,7 +327,7 @@ private async Task EnsureDispatchFinished(WorkerDispatcher jobDispatch, bool can
327
327
WorkerDispatcher workerDispatcher ;
328
328
if ( _jobInfos . TryRemove ( jobDispatch . JobId , out workerDispatcher ) )
329
329
{
330
- Trace . Verbose ( $ "Remove WorkerDispather from { nameof ( _jobInfos ) } dictionary for job { jobDispatch . JobId } .") ;
330
+ Trace . Verbose ( $ "Remove WorkerDispatcher from { nameof ( _jobInfos ) } dictionary for job { jobDispatch . JobId } .") ;
331
331
workerDispatcher . Dispose ( ) ;
332
332
}
333
333
}
0 commit comments