Skip to content
Snippets Groups Projects
Commit 560e08a0 authored by Tamas Gal's avatar Tamas Gal :speech_balloon:
Browse files

Fix annotation position

parent 47244ede
No related branches found
No related tags found
No related merge requests found
...@@ -65,6 +65,8 @@ class DOMHits(Module): ...@@ -65,6 +65,8 @@ class DOMHits(Module):
self.hits = deque(maxlen=1000) self.hits = deque(maxlen=1000)
self.triggered_hits = deque(maxlen=1000) self.triggered_hits = deque(maxlen=1000)
self.runchanges = defaultdict(int) self.runchanges = defaultdict(int)
self.n_events = 0
self.thread = threading.Thread(target=self.plot).start() self.thread = threading.Thread(target=self.plot).start()
def process(self, blob): def process(self, blob):
...@@ -74,6 +76,7 @@ class DOMHits(Module): ...@@ -74,6 +76,7 @@ class DOMHits(Module):
return blob return blob
self.runchanges[blob['EventInfo'].run_id[0]] += 1 self.runchanges[blob['EventInfo'].run_id[0]] += 1
self.n_events += 1
event_hits = blob['Hits'] event_hits = blob['Hits']
with lock: with lock:
hits = np.zeros(self.det.n_doms) hits = np.zeros(self.det.n_doms)
...@@ -138,7 +141,8 @@ class DOMHits(Module): ...@@ -138,7 +141,8 @@ class DOMHits(Module):
continue continue
self.print("Annotating run {} ({} events passed)".format( self.print("Annotating run {} ({} events passed)".format(
run, n_events_since_runchange)) run, n_events_since_runchange))
x_pos = self.max_events - n_events_since_runchange x_pos = min(self.n_events,
self.max_events) - n_events_since_runchange
plt.text( plt.text(
x_pos, x_pos,
self.det.n_doms, self.det.n_doms,
......
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