CollectCollectionSourceConnectorCommand

// Id: 124f371c-6cdf-4705-80ca-658e083c8b5e
using Api.Code;

var hangfireBackgroundCommandHandler = Activate<HangfireBackgroundCommandHandler>();
await hangfireBackgroundCommandHandler.DispatchOnQueue(
    "CollectCollectionSourceConnectorCommand",
    "Utopia.Contracts.CollectionSourceConnectors.CollectCollectionSourceConnectorCommand, Utopia.Contracts, Version=0.12.1622.0, Culture=neutral, PublicKeyToken=null",
    "{"ConnectorId":"34c6d587-04a8-4f10-9583-3e50607f2024"}");

Parameters

CurrentCulture
""
CurrentUICulture
""
QueueName
"005_sourceconnectors"

State

11/04/2024 16:06:44 (+1m 5.632s) Failed

Failed to change state to a 'Failed' one due to an exception after 10 retry attempts

MySql.Data.MySqlClient.MySqlException

Unable to connect to any of the specified MySQL hosts.

MySql.Data.MySqlClient.MySqlException: Unable to connect to any of the specified MySQL hosts. ---> System.Net.Internals.SocketExceptionFactory+ExtendedSocketException: Resource temporarily unavailable
   at System.Net.Dns.InternalGetHostByName(String hostName)
   at System.Net.Dns.ResolveCallback(Object context)
   at System.Net.Dns.HostResolutionEndHelper(IAsyncResult asyncResult)
   at System.Net.Dns.EndGetHostAddresses(IAsyncResult asyncResult)
   at System.Threading.Tasks.TaskFactory<TResult>.FromAsyncCoreLogic(IAsyncResult iar, Func<IAsyncResult, TResult> endFunction, Action<IAsyncResult> endAction, Task<TResult> promise, Boolean requiresSynchronization)
   --- End of inner exception stack trace ---
   at MySql.Data.MySqlClient.NativeDriver.<>c.<Open>b__40_0(Exception ex)
   at System.AggregateException.Handle(Func<Exception, Boolean> predicate)
   at MySql.Data.MySqlClient.NativeDriver.Open()
   at MySql.Data.MySqlClient.Driver.Open()
   at MySql.Data.MySqlClient.Driver.Create(MySqlConnectionStringBuilder settings)
   at MySql.Data.MySqlClient.MySqlPool.CreateNewPooledConnection()
   at MySql.Data.MySqlClient.MySqlPool.GetPooledConnection()
   at MySql.Data.MySqlClient.MySqlPool.TryToGetDriver()
   at MySql.Data.MySqlClient.MySqlPool.GetConnection()
   at MySql.Data.MySqlClient.MySqlConnection.Open()
   at MySql.Data.MySqlClient.MySqlConnection.<OpenAsync>b__78_0()
   at System.Threading.ExecutionContext.RunFromThreadPoolDispatchLoop(Thread threadPoolThread, ExecutionContext executionContext, ContextCallback callback, Object state)
   at System.Threading.Tasks.Task.ExecuteWithThreadLocal(Task& currentTaskSlot, Thread threadPoolThread)
   at ElmahCore.MySql.LogRepository.ExecuteNonQueryAsync(MySqlCommand command)
   at ElmahCore.MySql.LogRepository.LogAsync(Guid id, Error error)
   at ElmahCore.MySql.LogRepository.Log(Guid id, Error error)
   at ElmahCore.MySql.MySqlErrorLog.Log(Error error)
   at Api.Code.ElmahJobFilterAttribute.OnStateElection(ElectStateContext context) in /src/Api/Code/HangfireConfiguration.cs:201
   at Hangfire.States.StateMachine.InvokeOnStateElection(Tuple<IElectStateFilter, ElectStateContext> x)

+21ms Processing

Server:
utopia-microservices-7fc5dfffcb-xk8d6:sourcing:1
Worker:
ffcb5b1f

+22ms Enqueued

11/04/2024 16:05:38 Created