Skip to content

Instantly share code, notes, and snippets.

@dawehner
Created February 23, 2022 22:15
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dawehner/794e8882f7036669e72294195bdb7028 to your computer and use it in GitHub Desktop.
Save dawehner/794e8882f7036669e72294195bdb7028 to your computer and use it in GitHub Desktop.
return try context.application.eventLoopGroup.future(res.items)
.flatMapEach(on: context.application.eventLoopGroup.next()) { item in
return self.queue.dispatch(RepoParseJob.self, Repo(url: item.git_url), maxRetryCount: 3)
}.wait()
-------------
[3/3] Build complete!
[ WARNING ] The operation couldn’t be completed. (RediStack.RedisConnectionPoolError error 1.)
ERROR: Cannot schedule tasks on an EventLoop that has already shut down. This will be upgraded to a forced crash in future SwiftNIO versions.
[ ERROR ] error while closing connection [error: alreadyClosed, rdstk_conn_id: 86ECAABD-89BB-4001-890D-DC527EE785D3, rdstk_conpool_id: 6A4A4567-E47A-4C84-B5DA-99310C19786B]
[ ERROR ] error while closing connection [error: alreadyClosed, rdstk_conn_id: 2A8F1F9B-6C11-4517-B55E-CBA1C3D8E820, rdstk_conpool_id: 6A4A4567-E47A-4C84-B5DA-99310C19786B]
Swift/ErrorType.swift:200: Fatal error: Error raised at top level: RediStack.RedisConnectionPoolError(baseError: RediStack.RedisConnectionPoolError.BaseError.timedOutWaitingForConnection)
@dawehner
Copy link
Author

      return try self.queue.dispatch(RepoParseJob.self, Repo(url: "git://github.com/numtide/flake-utils.git"), maxRetryCount: 3).wait()

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment