diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index 3fa94093c921d224328a664de0c883a2a925011f..a141714c69aee94724952267905a19487a568613 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -62,14 +62,6 @@ test-py3.8:
- make test
<<: *junit_definition
-test-py3.8-no-numba:
- image: docker.km3net.de/base/python:3.8
- stage: test
- script:
- - *virtualenv_definition
- - DISABLE_NUMBA=1 make test
- <<: *junit_definition
-
code-style:
image: docker.km3net.de/base/python:3.7
stage: test
diff --git a/README.rst b/README.rst
index ad6f89e19aa8a9fb9cfd8878cdd6e4d843486d9e..543db640d5403c6217db48db73af9acf40bc869a 100644
--- a/README.rst
+++ b/README.rst
@@ -33,13 +33,6 @@ To get the latest (stable) development release::
**Reminder:** km3io is **not** dependent on aanet, ROOT or Jpp!
-Using km3io in Julia
-====================
-
-A clash of LLVM versions is very likely (``km3io`` uses ``numba`` for DAQ
-utilities). To disable ``numba``, set the environmental variable
-``DISABLE_NUMBA=1``.
-
Questions
=========
diff --git a/km3io/daq.py b/km3io/daq.py
index c5bbd95b13d84d832a2bb45b3078694452b96165..ef592c32a754a1d9a11c6516ce607a6470615bd4 100644
--- a/km3io/daq.py
+++ b/km3io/daq.py
@@ -2,24 +2,7 @@ import os
import uproot
import numpy as np
-if os.getenv("DISABLE_NUMBA"):
- print("Numba is disabled, DAQ helper functions will not work!")
-
- # A hack to to get the @vectorize, @guvectorize and nb.types silently pass.
- def dummy_decorator(*args, **kwargs):
- def decorator(f):
- def wrapper(*args, **kwargs):
- return dummy_decorator(*args, **kwargs)
-
- return wrapper
-
- return decorator
-
- vectorize = dummy_decorator
- guvectorize = dummy_decorator
- int8 = int16 = int32 = int64 = dummy_decorator
-else:
- from numba import vectorize, guvectorize, int8, int16, int32, int64
+import numba as nb
TIMESLICE_FRAME_BASKET_CACHE_SIZE = 523 * 1024**2 # [byte]
SUMMARYSLICE_FRAME_BASKET_CACHE_SIZE = 523 * 1024**2 # [byte]
@@ -35,7 +18,12 @@ RATE_FACTOR = np.log(MAXIMAL_RATE_HZ / MINIMAL_RATE_HZ) / 255
CHANNEL_BITS_TEMPLATE = np.zeros(31, dtype=bool)
-@vectorize([int32(int8), int32(int16), int32(int32), int32(int64)])
+@nb.vectorize([
+ nb.int32(nb.int8),
+ nb.int32(nb.int16),
+ nb.int32(nb.int32),
+ nb.int32(nb.int64)
+])
def get_rate(value): #pragma: no cover
"""Return the rate in Hz from the short int value"""
if value == 0:
@@ -44,10 +32,10 @@ def get_rate(value): #pragma: no cover
return MINIMAL_RATE_HZ * np.exp(value * RATE_FACTOR)
-@guvectorize("void(i8, b1[:], b1[:])",
- "(), (n) -> (n)",
- target="parallel",
- nopython=True)
+@nb.guvectorize("void(i8, b1[:], b1[:])",
+ "(), (n) -> (n)",
+ target="parallel",
+ nopython=True)
def unpack_bits(value, bits_template, out): #pragma: no cover
"""Return a boolean array for a value's bit representation.
diff --git a/tests/test_daq.py b/tests/test_daq.py
index e378b4a3119203231b9300a7f2be50179b54a65e..7482e09d51ec170073a6738d0314ca19e4d05986 100644
--- a/tests/test_daq.py
+++ b/tests/test_daq.py
@@ -175,7 +175,6 @@ class TestSummaryslices(unittest.TestCase):
def test_rates(self):
assert 3 == len(self.ss.rates)
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_fifo(self):
s = self.ss.slices[0]
dct_fifo_stat = {
@@ -188,7 +187,6 @@ class TestSummaryslices(unittest.TestCase):
frame = s[s.dom_id == dom_id]
assert any(get_channel_flags(frame.fifo[0])) == fifo_status
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_has_udp_trailer(self):
s = self.ss.slices[0]
dct_udp_trailer = {
@@ -208,7 +206,6 @@ class TestSummaryslices(unittest.TestCase):
frame = s[s.dom_id == dom_id]
assert has_udp_trailer(frame.fifo[0]) == udp_trailer
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_high_rate_veto(self):
s = self.ss.slices[0]
dct_high_rate_veto = {
@@ -249,7 +246,6 @@ class TestSummaryslices(unittest.TestCase):
frame = s[s.dom_id == dom_id]
assert any(get_channel_flags(frame.hrv[0])) == high_rate_veto
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_max_sequence_number(self):
s = self.ss.slices[0]
dct_seq_numbers = {
@@ -287,7 +283,6 @@ class TestSummaryslices(unittest.TestCase):
assert get_udp_max_sequence_number(
frame.dq_status[0]) == max_sequence_number
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_number_udp_packets(self):
s = self.ss.slices[0]
dct_n_packets = {
@@ -317,7 +312,6 @@ class TestSummaryslices(unittest.TestCase):
frame = s[s.dom_id == dom_id]
assert get_number_udp_packets(frame.dq_status[0]) == n_udp_packets
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_hrv_flags(self):
s = self.ss.slices[0]
dct_hrv_flags = {
@@ -353,7 +347,6 @@ class TestSummaryslices(unittest.TestCase):
for a, b in zip(get_channel_flags(frame.hrv[0]), hrv_flags)
])
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_fifo_flags(self):
s = self.ss.slices[0]
dct_fifo_flags = {
@@ -406,17 +399,14 @@ class TestSummaryslices(unittest.TestCase):
class TestGetRate(unittest.TestCase):
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_zero(self):
assert 0 == get_rate(0)
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_some_values(self):
assert 2054 == get_rate(1)
assert 55987 == get_rate(123)
assert 1999999 == get_rate(255)
- @unittest.skipIf(os.getenv("DISABLE_NUMBA"), reason="no numba")
def test_vectorized_input(self):
self.assertListEqual([2054], list(get_rate([1])))
self.assertListEqual([2054, 2111, 2169], list(get_rate([1, 2, 3])))