Skip to content
Snippets Groups Projects
Verified Commit 0a2efb0b authored by Volker Schukai's avatar Volker Schukai :alien:
Browse files

fix: type

parent bd92d57d
No related branches found
No related tags found
No related merge requests found
......@@ -7,7 +7,6 @@
<list default="true" id="9979eb22-471e-4f2f-b624-fd3edb5e8c6e" name="Changes" comment="">
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/manager.go" beforeDir="false" afterPath="$PROJECT_DIR$/manager.go" afterDir="false" />
<change beforePath="$PROJECT_DIR$/queue.go" beforeDir="false" afterPath="$PROJECT_DIR$/queue.go" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
......@@ -259,7 +258,7 @@
<workItem from="1734022155342" duration="424000" />
<workItem from="1734024671338" duration="1103000" />
<workItem from="1734042130391" duration="922000" />
<workItem from="1734047047039" duration="578000" />
<workItem from="1734047047039" duration="1146000" />
</task>
<servers />
</component>
......
......@@ -60,7 +60,6 @@ func NewManager() *Manager {
}
// GetEventBus returns the event bus
func (m *Manager) GetEventBus() *EventBus {
m.mu.Lock()
......@@ -828,7 +827,7 @@ func (m *Manager) Stats() ManagerStats {
subscriberJobReady := len(m.eventBus.subscribers[JobReady])
subscriberQueueJob := len(m.eventBus.subscribers[QueueJob])
subscriberJobFinished := len(m.eventBus.subscribers[JobFinished])
subscriberJobDone := len(m.eventBus.subscribers[JobDone)
subscriberJobDone := len(m.eventBus.subscribers[JobDone])
return ManagerStats{
ReadyQueueLength: readyQueueLength,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment