diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add/1.json b/beat/backend/python/test/prefix/algorithms/autonomous/add/1.json
index 0ec3448502ce407d6971b59a2073c1ecc7948228..61b4c2f221f2e5d10917d029592d96102867dfa9 100644
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add/1.json
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add/1.json
@@ -27,4 +27,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/add/1.py
index d473d82e7ccfa5a8d8365a8e2134be7eb2b8f59c..fecf0c1aa09b00a8efb8f90afe7fdde44212ae53 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add/1.py
@@ -35,24 +35,18 @@
class Algorithm:
-
def setup(self, parameters):
- self.sync = parameters['sync']
+ self.sync = parameters["sync"]
return True
-
def process(self, data_loaders, outputs):
- data_loader = data_loaders.loaderOf('in1')
+ data_loader = data_loaders.loaderOf("in1")
for i in range(data_loader.count(self.sync)):
view = data_loader.view(self.sync, i)
(data, start, end) = view[view.count() - 1]
- outputs['out'].write({
- 'value': data['in1'].value + data['in2'].value,
- },
- end
- )
+ outputs["out"].write({"value": data["in1"].value + data["in2"].value}, end)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.json b/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.json
index 966623ea711f2e7d413c5615939890f7bdc01ee5..ae67a982673f361cfd3f2644f2101d49486b9f0a 100644
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.json
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.json
@@ -25,4 +25,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.py
index 2b204417f9179ebe24701120553a8daf5ef92395..7674616acbc29db49a878766a4671191eced8c95 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add2/1.py
@@ -35,26 +35,20 @@
class Algorithm:
-
def prepare(self, data_loaders):
- data_loader = data_loaders.loaderOf('in2')
+ data_loader = data_loaders.loaderOf("in2")
(data, start, end) = data_loader[0]
- self.offset = data['in2'].value
+ self.offset = data["in2"].value
return True
-
def process(self, data_loaders, outputs):
- data_loader = data_loaders.loaderOf('in1')
+ data_loader = data_loaders.loaderOf("in1")
for i in range(data_loader.count()):
(data, start, end) = data_loader[i]
- outputs['out'].write({
- 'value': data['in1'].value + self.offset,
- },
- end
- )
+ outputs["out"].write({"value": data["in1"].value + self.offset}, end)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.json b/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.json
index cefb5e014be1e718321ba5a7e13854e23fe131ca..ab5d326e6ba588cd0aed6e3a9a00b3ad55cbbeb5 100644
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.json
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.json
@@ -28,4 +28,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.py
index 69686cf9665bf46ad0d1515b05010c91bf192fb9..65af3ecd0b65e61e63f7a700d999cc7c31ea4f41 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/add3/1.py
@@ -35,21 +35,18 @@
class Algorithm:
-
def process(self, data_loaders, outputs):
- values = data_loaders.loaderOf('value')
- offsets = data_loaders.loaderOf('offset')
+ values = data_loaders.loaderOf("value")
+ offsets = data_loaders.loaderOf("offset")
for i in range(values.count()):
(data, start, end) = values[i]
- offset_index = data['offset_index'].value
+ offset_index = data["offset_index"].value
(data2, start2, end2) = offsets[offset_index]
- outputs['out'].write({
- 'value': data['value'].value + data2['offset'].value,
- },
- end
+ outputs["out"].write(
+ {"value": data["value"].value + data2["offset"].value}, end
)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/echo/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/echo/1.py
index f5eb2bf20da2db2ac6ef56a854d19d706092da2c..62e1db7d22b4f69cf8d8d96cfe5d5fa80bdaa61f 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/echo/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/echo/1.py
@@ -35,17 +35,12 @@
class Algorithm:
-
def process(self, data_loaders, outputs):
- data_loader = data_loaders.loaderOf('in')
+ data_loader = data_loaders.loaderOf("in")
for i in range(data_loader.count()):
(data, start, end) = data_loader[i]
- outputs['out'].write({
- 'value': data['in'].value,
- },
- end
- )
+ outputs["out"].write({"value": data["in"].value}, end)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/no_prepare/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/no_prepare/1.py
index b8f66a850c5f48e596829377faf68417d2716268..d42545b009595bcfb17ef587e5d554578723af5f 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/no_prepare/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/no_prepare/1.py
@@ -35,6 +35,5 @@
class Algorithm:
-
def process(self, data_loaders, outputs):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/no_setup/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/no_setup/1.py
index c20717d1a66824e469695c89f66c88f7a2c6b1fd..c5b1c86ed5b6dedef5dd25a6ce5165f80d8a974e 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/no_setup/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/no_setup/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/parametrized/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/parametrized/1.py
index 51d86deca79ddf80fbf90d3a7e796cbc98cffd9c..bc78541f614eed1f689841057c53a6ec3e0b33f1 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/parametrized/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/parametrized/1.py
@@ -35,40 +35,39 @@
class Algorithm:
-
def setup(self, parameters):
- self.int8_value = parameters['int8_value']
- self.int8_range = parameters['int8_range']
- self.int8_choices = parameters['int8_choices']
- self.int16_value = parameters['int16_value']
- self.int16_range = parameters['int16_range']
- self.int16_choices = parameters['int16_choices']
- self.int32_value = parameters['int32_value']
- self.int32_range = parameters['int32_range']
- self.int32_choices = parameters['int32_choices']
- self.int64_value = parameters['int64_value']
- self.int64_range = parameters['int64_range']
- self.int64_choices = parameters['int64_choices']
- self.uint8_value = parameters['uint8_value']
- self.uint8_range = parameters['uint8_range']
- self.uint8_choices = parameters['uint8_choices']
- self.uint16_value = parameters['uint16_value']
- self.uint16_range = parameters['uint16_range']
- self.uint16_choices = parameters['uint16_choices']
- self.uint32_value = parameters['uint32_value']
- self.uint32_range = parameters['uint32_range']
- self.uint32_choices = parameters['uint32_choices']
- self.uint64_value = parameters['uint64_value']
- self.uint64_range = parameters['uint64_range']
- self.uint64_choices = parameters['uint64_choices']
- self.float32_value = parameters['float32_value']
- self.float32_range = parameters['float32_range']
- self.float32_choices = parameters['float32_choices']
- self.float64_value = parameters['float64_value']
- self.float64_range = parameters['float64_range']
- self.float64_choices = parameters['float64_choices']
- self.bool_value = parameters['bool_value']
- self.string_value = parameters['string_value']
+ self.int8_value = parameters["int8_value"]
+ self.int8_range = parameters["int8_range"]
+ self.int8_choices = parameters["int8_choices"]
+ self.int16_value = parameters["int16_value"]
+ self.int16_range = parameters["int16_range"]
+ self.int16_choices = parameters["int16_choices"]
+ self.int32_value = parameters["int32_value"]
+ self.int32_range = parameters["int32_range"]
+ self.int32_choices = parameters["int32_choices"]
+ self.int64_value = parameters["int64_value"]
+ self.int64_range = parameters["int64_range"]
+ self.int64_choices = parameters["int64_choices"]
+ self.uint8_value = parameters["uint8_value"]
+ self.uint8_range = parameters["uint8_range"]
+ self.uint8_choices = parameters["uint8_choices"]
+ self.uint16_value = parameters["uint16_value"]
+ self.uint16_range = parameters["uint16_range"]
+ self.uint16_choices = parameters["uint16_choices"]
+ self.uint32_value = parameters["uint32_value"]
+ self.uint32_range = parameters["uint32_range"]
+ self.uint32_choices = parameters["uint32_choices"]
+ self.uint64_value = parameters["uint64_value"]
+ self.uint64_range = parameters["uint64_range"]
+ self.uint64_choices = parameters["uint64_choices"]
+ self.float32_value = parameters["float32_value"]
+ self.float32_range = parameters["float32_range"]
+ self.float32_choices = parameters["float32_choices"]
+ self.float64_value = parameters["float64_value"]
+ self.float64_range = parameters["float64_range"]
+ self.float64_choices = parameters["float64_choices"]
+ self.bool_value = parameters["bool_value"]
+ self.string_value = parameters["string_value"]
return True
def process(self, data_loaders, outputs):
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/prepare_crash/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/prepare_crash/1.py
index 6baa70fa8289dcd2ccc73ad78f61a6c388d0826d..7613c560ae83a8fa3ec046624234320ef2011385 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/prepare_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/prepare_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/prepare_fail/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/prepare_fail/1.py
index b5a91c86f390a8fef9f5fb5b7d43df45485a5eaf..ec35cda6005c669913a751b825591ae40eeb5e63 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/prepare_fail/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/prepare_fail/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
return False
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/process_crash/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/process_crash/1.py
index 1764aa3ac677ab87695ec4ae4275c5ab1c388a8b..363dd05431d6addfab34f344e26faae041cf0362 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/process_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/process_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def process(self, data_loaders, outputs):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/setup_crash/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/setup_crash/1.py
index 1d9656b9e484a26c896b2f6718080dd7dc5c9397..bcfb17bdc1436d0b9a01f0cdb9db604db2d7be3a 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/setup_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/setup_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/setup_fail/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/setup_fail/1.py
index a3f7fb081bdadb463781d0da211bf681ae901a83..d6ee28a1358518d0892a90605ee7446c4180aead 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/setup_fail/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/setup_fail/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return False
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/valid_algorithm/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/valid_algorithm/1.py
index a9c42ecf1139d018a646fca5b66edab62c68607e..a91aa2a4bee5fedd9e8956e30f09aa850718dc4d 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/valid_algorithm/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/valid_algorithm/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/autonomous/valid_analysis/1.py b/beat/backend/python/test/prefix/algorithms/autonomous/valid_analysis/1.py
index 3316c1c932bbe353826c2f61b01570b1534a51df..6739f2dbe34ec67f9dca135af7db8a9cf1ef8ca5 100755
--- a/beat/backend/python/test/prefix/algorithms/autonomous/valid_analysis/1.py
+++ b/beat/backend/python/test/prefix/algorithms/autonomous/valid_analysis/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/add/1.json b/beat/backend/python/test/prefix/algorithms/legacy/add/1.json
index 51ba4f232957d6368a27abe23abe139e909a6abe..b1a0101df0af914c49e3696cff984de5c840ace2 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/add/1.json
+++ b/beat/backend/python/test/prefix/algorithms/legacy/add/1.json
@@ -24,4 +24,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/add/1.py b/beat/backend/python/test/prefix/algorithms/legacy/add/1.py
index 4672ee59494671668d80387a8e3cf5442d7cffa7..a1ef20a048a6459079939433e5fc1148d0e58cd0 100755
--- a/beat/backend/python/test/prefix/algorithms/legacy/add/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/add/1.py
@@ -35,16 +35,14 @@
class Algorithm:
-
def setup(self, parameters):
- self.sync = parameters['sync']
+ self.sync = parameters["sync"]
return True
-
def process(self, inputs, outputs):
if inputs[self.sync].isDataUnitDone():
- outputs['out'].write({
- 'value': inputs['in1'].data.value + inputs['in2'].data.value,
- })
+ outputs["out"].write(
+ {"value": inputs["in1"].data.value + inputs["in2"].data.value}
+ )
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/add2/1.json b/beat/backend/python/test/prefix/algorithms/legacy/add2/1.json
index 20715dc20bbb0b65df1afd6ee5d432de32f7d45b..c55c48d0cf5d15e9e0608754109996c31b5e7e56 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/add2/1.json
+++ b/beat/backend/python/test/prefix/algorithms/legacy/add2/1.json
@@ -22,4 +22,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/add2/1.py b/beat/backend/python/test/prefix/algorithms/legacy/add2/1.py
index 27569adbfac984a5b7de40d7ff8114e8d113fe18..a3648e27ced2634a7d1b58d3f4077785b76dd2b1 100755
--- a/beat/backend/python/test/prefix/algorithms/legacy/add2/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/add2/1.py
@@ -35,18 +35,15 @@
class Algorithm:
-
def __init__(self):
self.offset = None
def process(self, inputs, outputs):
if self.offset is None:
- group = inputs.groupOf('in2')
+ group = inputs.groupOf("in2")
group.next()
- self.offset = group['in2'].data.value
+ self.offset = group["in2"].data.value
- outputs['out'].write({
- 'value': inputs['in1'].data.value + self.offset,
- })
+ outputs["out"].write({"value": inputs["in1"].data.value + self.offset})
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/echo/1.py b/beat/backend/python/test/prefix/algorithms/legacy/echo/1.py
index bb539b5d7fe336a2cc3dd2506d0117bd6e0d3f5a..617a535ef3c71c6bf48c0f986615303ef3e7952a 100755
--- a/beat/backend/python/test/prefix/algorithms/legacy/echo/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/echo/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def process(self, inputs, outputs):
- outputs['out'].write(inputs['in'].data)
+ outputs["out"].write(inputs["in"].data)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/no_class/1.py b/beat/backend/python/test/prefix/algorithms/legacy/no_class/1.py
index 74316022bb9df16b5d7c219f39723f3fb8e24a28..a511954e13f46ac43fd9413aab29f865e980face 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/no_class/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/no_class/1.py
@@ -35,6 +35,5 @@
class InvalidAlgorithmClassName:
-
def process(self, inputs, outputs):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/no_setup/1.py b/beat/backend/python/test/prefix/algorithms/legacy/no_setup/1.py
index 7cf2d9a6025fffa5195e38a41d2b91c9905ca454..164f5ad741e0db32021d2f210243cf9871ba449b 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/no_setup/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/no_setup/1.py
@@ -35,6 +35,5 @@
class Algorithm:
-
def process(self, inputs, outputs):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/parametrized/1.py b/beat/backend/python/test/prefix/algorithms/legacy/parametrized/1.py
index 9cd88363672c5f2ca0c4327817fbb3eab693fea6..b80a6f0ab25e4c7467a0b7a8b7f936616b2dde50 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/parametrized/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/parametrized/1.py
@@ -35,40 +35,39 @@
class Algorithm:
-
def setup(self, parameters):
- self.int8_value = parameters['int8_value']
- self.int8_range = parameters['int8_range']
- self.int8_choices = parameters['int8_choices']
- self.int16_value = parameters['int16_value']
- self.int16_range = parameters['int16_range']
- self.int16_choices = parameters['int16_choices']
- self.int32_value = parameters['int32_value']
- self.int32_range = parameters['int32_range']
- self.int32_choices = parameters['int32_choices']
- self.int64_value = parameters['int64_value']
- self.int64_range = parameters['int64_range']
- self.int64_choices = parameters['int64_choices']
- self.uint8_value = parameters['uint8_value']
- self.uint8_range = parameters['uint8_range']
- self.uint8_choices = parameters['uint8_choices']
- self.uint16_value = parameters['uint16_value']
- self.uint16_range = parameters['uint16_range']
- self.uint16_choices = parameters['uint16_choices']
- self.uint32_value = parameters['uint32_value']
- self.uint32_range = parameters['uint32_range']
- self.uint32_choices = parameters['uint32_choices']
- self.uint64_value = parameters['uint64_value']
- self.uint64_range = parameters['uint64_range']
- self.uint64_choices = parameters['uint64_choices']
- self.float32_value = parameters['float32_value']
- self.float32_range = parameters['float32_range']
- self.float32_choices = parameters['float32_choices']
- self.float64_value = parameters['float64_value']
- self.float64_range = parameters['float64_range']
- self.float64_choices = parameters['float64_choices']
- self.bool_value = parameters['bool_value']
- self.string_value = parameters['string_value']
+ self.int8_value = parameters["int8_value"]
+ self.int8_range = parameters["int8_range"]
+ self.int8_choices = parameters["int8_choices"]
+ self.int16_value = parameters["int16_value"]
+ self.int16_range = parameters["int16_range"]
+ self.int16_choices = parameters["int16_choices"]
+ self.int32_value = parameters["int32_value"]
+ self.int32_range = parameters["int32_range"]
+ self.int32_choices = parameters["int32_choices"]
+ self.int64_value = parameters["int64_value"]
+ self.int64_range = parameters["int64_range"]
+ self.int64_choices = parameters["int64_choices"]
+ self.uint8_value = parameters["uint8_value"]
+ self.uint8_range = parameters["uint8_range"]
+ self.uint8_choices = parameters["uint8_choices"]
+ self.uint16_value = parameters["uint16_value"]
+ self.uint16_range = parameters["uint16_range"]
+ self.uint16_choices = parameters["uint16_choices"]
+ self.uint32_value = parameters["uint32_value"]
+ self.uint32_range = parameters["uint32_range"]
+ self.uint32_choices = parameters["uint32_choices"]
+ self.uint64_value = parameters["uint64_value"]
+ self.uint64_range = parameters["uint64_range"]
+ self.uint64_choices = parameters["uint64_choices"]
+ self.float32_value = parameters["float32_value"]
+ self.float32_range = parameters["float32_range"]
+ self.float32_choices = parameters["float32_choices"]
+ self.float64_value = parameters["float64_value"]
+ self.float64_range = parameters["float64_range"]
+ self.float64_choices = parameters["float64_choices"]
+ self.bool_value = parameters["bool_value"]
+ self.string_value = parameters["string_value"]
return True
def process(self, inputs, outputs):
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.json b/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.json
index 51ba4f232957d6368a27abe23abe139e909a6abe..b1a0101df0af914c49e3696cff984de5c840ace2 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.json
+++ b/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.json
@@ -24,4 +24,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.py b/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.py
index b85d1497c014d00487a290710a363d3fce882099..d7e842a594c83890a9f816adaa3b520723b39ae1 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/prepare/1.py
@@ -35,18 +35,17 @@
class Algorithm:
-
def setup(self, parameters):
- self.sync = parameters['sync']
+ self.sync = parameters["sync"]
return True
def prepare(self):
- return True
+ return True
def process(self, inputs, outputs):
if inputs[self.sync].isDataUnitDone():
- outputs['out'].write({
- 'value': inputs['in1'].data.value + inputs['in2'].data.value,
- })
+ outputs["out"].write(
+ {"value": inputs["in1"].data.value + inputs["in2"].data.value}
+ )
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/process_crash/1.py b/beat/backend/python/test/prefix/algorithms/legacy/process_crash/1.py
index 4d539211a248422983bfc90bde72ae696f4558b7..bec1160e777e8b957341e054c47d473a71b89875 100755
--- a/beat/backend/python/test/prefix/algorithms/legacy/process_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/process_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def process(self, inputs, outputs):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/setup_crash/1.py b/beat/backend/python/test/prefix/algorithms/legacy/setup_crash/1.py
index 5e9344e1690f6fb3bc200d137b629ada7c17d545..7a2c23054471b0c29446b5eb2f299fe7cbcfc507 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/setup_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/setup_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/setup_fail/1.py b/beat/backend/python/test/prefix/algorithms/legacy/setup_fail/1.py
index f4cf20867a5c64f1a7a868290f2edf32528dc1d6..0c7621126ca743ed45896cbf9cb9c27a58a236d9 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/setup_fail/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/setup_fail/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return False
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/valid_algorithm/1.py b/beat/backend/python/test/prefix/algorithms/legacy/valid_algorithm/1.py
index 7cf2d9a6025fffa5195e38a41d2b91c9905ca454..164f5ad741e0db32021d2f210243cf9871ba449b 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/valid_algorithm/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/valid_algorithm/1.py
@@ -35,6 +35,5 @@
class Algorithm:
-
def process(self, inputs, outputs):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/legacy/valid_analysis/1.py b/beat/backend/python/test/prefix/algorithms/legacy/valid_analysis/1.py
index bdfc072a1d4e92e2d4d3eca332a53467a7cf903c..cca68694a3f204656a86d92275c4c76e56d50584 100644
--- a/beat/backend/python/test/prefix/algorithms/legacy/valid_analysis/1.py
+++ b/beat/backend/python/test/prefix/algorithms/legacy/valid_analysis/1.py
@@ -35,6 +35,5 @@
class Algorithm:
-
def process(self, inputs, output):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add/1.json b/beat/backend/python/test/prefix/algorithms/sequential/add/1.json
index 9f4576d52619443a800ec1f98fd51675bc57ecec..8a6217cf6825553b8216d8f2b0d6adb6e6782174 100644
--- a/beat/backend/python/test/prefix/algorithms/sequential/add/1.json
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add/1.json
@@ -27,4 +27,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add/1.py b/beat/backend/python/test/prefix/algorithms/sequential/add/1.py
index a264b3f7e85f450fa552abb792512b009b9d947c..705c0c3e627c2467bcc7bd351bfe0987053b81c8 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/add/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add/1.py
@@ -35,16 +35,14 @@
class Algorithm:
-
def setup(self, parameters):
- self.sync = parameters['sync']
+ self.sync = parameters["sync"]
return True
-
def process(self, inputs, data_loaders, outputs):
if inputs[self.sync].isDataUnitDone():
- outputs['out'].write({
- 'value': inputs['in1'].data.value + inputs['in2'].data.value,
- })
+ outputs["out"].write(
+ {"value": inputs["in1"].data.value + inputs["in2"].data.value}
+ )
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add2/1.json b/beat/backend/python/test/prefix/algorithms/sequential/add2/1.json
index 69d95bfd64e36dd83fd6d5968319412792aa4fe2..34eaad0afbd6ff649d39848a0c3eae0451da4a03 100644
--- a/beat/backend/python/test/prefix/algorithms/sequential/add2/1.json
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add2/1.json
@@ -25,4 +25,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add2/1.py b/beat/backend/python/test/prefix/algorithms/sequential/add2/1.py
index ab96080808bf3adb85437de0e24f41ff40551fd8..5e92ca03db1e2266f5171c7216d38660709c2f27 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/add2/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add2/1.py
@@ -35,19 +35,15 @@
class Algorithm:
-
def prepare(self, data_loaders):
- data_loader = data_loaders.loaderOf('in2')
+ data_loader = data_loaders.loaderOf("in2")
(data, start, end) = data_loader[0]
- self.offset = data['in2'].value
+ self.offset = data["in2"].value
return True
-
def process(self, inputs, data_loaders, outputs):
- outputs['out'].write({
- 'value': inputs['in1'].data.value + self.offset,
- })
+ outputs["out"].write({"value": inputs["in1"].data.value + self.offset})
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add3/1.json b/beat/backend/python/test/prefix/algorithms/sequential/add3/1.json
index a46209696a54d08fe30dea6e2efe76e292a2c2d5..db8588f73c9fe950bde2c6503f63b2fe9198299d 100644
--- a/beat/backend/python/test/prefix/algorithms/sequential/add3/1.json
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add3/1.json
@@ -28,4 +28,4 @@
}
}
]
-}
\ No newline at end of file
+}
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/add3/1.py b/beat/backend/python/test/prefix/algorithms/sequential/add3/1.py
index 87e8636132c4384fd823b72dc5f25d659505c6ca..b9bcd0b5aec8b4aff4e59803cc81c0094ec49d2c 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/add3/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/add3/1.py
@@ -35,15 +35,14 @@
class Algorithm:
-
def process(self, inputs, data_loaders, outputs):
- offset_index = inputs['offset_index'].data.value
+ offset_index = inputs["offset_index"].data.value
- data_loader = data_loaders.loaderOf('offset')
+ data_loader = data_loaders.loaderOf("offset")
(data, start, end) = data_loader[offset_index]
- outputs['out'].write({
- 'value': inputs['value'].data.value + data['offset'].value,
- })
+ outputs["out"].write(
+ {"value": inputs["value"].data.value + data["offset"].value}
+ )
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/echo/1.py b/beat/backend/python/test/prefix/algorithms/sequential/echo/1.py
index e7d9d7dafd5874a6e9ceca17cee819ef9383ebc9..987dea5cee5724a391f51ea2dc8570d5c3774366 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/echo/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/echo/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def process(self, inputs, data_loaders, outputs):
- outputs['out'].write(inputs['in'].data)
+ outputs["out"].write(inputs["in"].data)
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/no_prepare/1.py b/beat/backend/python/test/prefix/algorithms/sequential/no_prepare/1.py
index 88c5e50f7ec24372988986b58e8f5177be1e9aa1..c042564edbc1e65f624b8d192f4a3927f8cd9c0e 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/no_prepare/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/no_prepare/1.py
@@ -35,6 +35,5 @@
class Algorithm:
-
def process(self, inputs, data_loaders, outputs):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/no_setup/1.py b/beat/backend/python/test/prefix/algorithms/sequential/no_setup/1.py
index c20717d1a66824e469695c89f66c88f7a2c6b1fd..c5b1c86ed5b6dedef5dd25a6ce5165f80d8a974e 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/no_setup/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/no_setup/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/parametrized/1.py b/beat/backend/python/test/prefix/algorithms/sequential/parametrized/1.py
index 7f566c53f84fc78550b4f465f3ad725727855575..dac535dbd756a9713376d3b22285454dc526e042 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/parametrized/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/parametrized/1.py
@@ -35,40 +35,39 @@
class Algorithm:
-
def setup(self, parameters):
- self.int8_value = parameters['int8_value']
- self.int8_range = parameters['int8_range']
- self.int8_choices = parameters['int8_choices']
- self.int16_value = parameters['int16_value']
- self.int16_range = parameters['int16_range']
- self.int16_choices = parameters['int16_choices']
- self.int32_value = parameters['int32_value']
- self.int32_range = parameters['int32_range']
- self.int32_choices = parameters['int32_choices']
- self.int64_value = parameters['int64_value']
- self.int64_range = parameters['int64_range']
- self.int64_choices = parameters['int64_choices']
- self.uint8_value = parameters['uint8_value']
- self.uint8_range = parameters['uint8_range']
- self.uint8_choices = parameters['uint8_choices']
- self.uint16_value = parameters['uint16_value']
- self.uint16_range = parameters['uint16_range']
- self.uint16_choices = parameters['uint16_choices']
- self.uint32_value = parameters['uint32_value']
- self.uint32_range = parameters['uint32_range']
- self.uint32_choices = parameters['uint32_choices']
- self.uint64_value = parameters['uint64_value']
- self.uint64_range = parameters['uint64_range']
- self.uint64_choices = parameters['uint64_choices']
- self.float32_value = parameters['float32_value']
- self.float32_range = parameters['float32_range']
- self.float32_choices = parameters['float32_choices']
- self.float64_value = parameters['float64_value']
- self.float64_range = parameters['float64_range']
- self.float64_choices = parameters['float64_choices']
- self.bool_value = parameters['bool_value']
- self.string_value = parameters['string_value']
+ self.int8_value = parameters["int8_value"]
+ self.int8_range = parameters["int8_range"]
+ self.int8_choices = parameters["int8_choices"]
+ self.int16_value = parameters["int16_value"]
+ self.int16_range = parameters["int16_range"]
+ self.int16_choices = parameters["int16_choices"]
+ self.int32_value = parameters["int32_value"]
+ self.int32_range = parameters["int32_range"]
+ self.int32_choices = parameters["int32_choices"]
+ self.int64_value = parameters["int64_value"]
+ self.int64_range = parameters["int64_range"]
+ self.int64_choices = parameters["int64_choices"]
+ self.uint8_value = parameters["uint8_value"]
+ self.uint8_range = parameters["uint8_range"]
+ self.uint8_choices = parameters["uint8_choices"]
+ self.uint16_value = parameters["uint16_value"]
+ self.uint16_range = parameters["uint16_range"]
+ self.uint16_choices = parameters["uint16_choices"]
+ self.uint32_value = parameters["uint32_value"]
+ self.uint32_range = parameters["uint32_range"]
+ self.uint32_choices = parameters["uint32_choices"]
+ self.uint64_value = parameters["uint64_value"]
+ self.uint64_range = parameters["uint64_range"]
+ self.uint64_choices = parameters["uint64_choices"]
+ self.float32_value = parameters["float32_value"]
+ self.float32_range = parameters["float32_range"]
+ self.float32_choices = parameters["float32_choices"]
+ self.float64_value = parameters["float64_value"]
+ self.float64_range = parameters["float64_range"]
+ self.float64_choices = parameters["float64_choices"]
+ self.bool_value = parameters["bool_value"]
+ self.string_value = parameters["string_value"]
return True
def process(self, inputs, data_loaders, outputs):
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/prepare_crash/1.py b/beat/backend/python/test/prefix/algorithms/sequential/prepare_crash/1.py
index 7aee81e2402c9ea6a2051bb1c1b8a4f69b45e445..94555de404295c6db638f89e332e841735c84279 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/prepare_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/prepare_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/prepare_fail/1.py b/beat/backend/python/test/prefix/algorithms/sequential/prepare_fail/1.py
index aa554a6aac4fa6271e34ecf036fa9e1b3bd37d6a..d108c0bef168a2a3e4977fcb86844e62a243e715 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/prepare_fail/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/prepare_fail/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def prepare(self, data_loaders):
return False
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/process_crash/1.py b/beat/backend/python/test/prefix/algorithms/sequential/process_crash/1.py
index 2897e76cc03bada124e65543889fb30eb85c58e0..5c66a9f8d2a671bd525d59797ac2321ca322615b 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/process_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/process_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def process(self, inputs, data_loaders, outputs):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/setup_crash/1.py b/beat/backend/python/test/prefix/algorithms/sequential/setup_crash/1.py
index 964b6df608acce0aa6da24bab5adac621c6259b5..1c004f3ea133ed8f43e234d99c7eedf188e041a3 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/setup_crash/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/setup_crash/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
a = b
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/setup_fail/1.py b/beat/backend/python/test/prefix/algorithms/sequential/setup_fail/1.py
index acb524702e0da977932937b3031905f91417ecbe..921890b3b4c1d78179da6ca91662589b76cc8f90 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/setup_fail/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/setup_fail/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return False
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/valid_algorithm/1.py b/beat/backend/python/test/prefix/algorithms/sequential/valid_algorithm/1.py
index 982c1e2bb853f551b4e6d650be55065acbacc5bf..3b19beb98b11bb7d8234bf072ccbe5ab974a0327 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/valid_algorithm/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/valid_algorithm/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return True
diff --git a/beat/backend/python/test/prefix/algorithms/sequential/valid_analysis/1.py b/beat/backend/python/test/prefix/algorithms/sequential/valid_analysis/1.py
index 9b55464de176ee04c12e9316130f6c1c9de469b7..8caf7a45b06bfd8c37179f5bcf4799e65032603f 100755
--- a/beat/backend/python/test/prefix/algorithms/sequential/valid_analysis/1.py
+++ b/beat/backend/python/test/prefix/algorithms/sequential/valid_analysis/1.py
@@ -35,7 +35,6 @@
class Algorithm:
-
def setup(self, parameters):
return True
diff --git a/beat/backend/python/test/prefix/databases/crash/1.py b/beat/backend/python/test/prefix/databases/crash/1.py
index 956d118d6a10fda8feae928975715d8cb543a102..abf25bbdba51793df441731ffaee3e50aab5ed52 100755
--- a/beat/backend/python/test/prefix/databases/crash/1.py
+++ b/beat/backend/python/test/prefix/databases/crash/1.py
@@ -34,12 +34,12 @@
###################################################################################
-from beat.backend.python.database import View
from collections import namedtuple
+from beat.backend.python.database import View
-class IndexCrashes(View):
+class IndexCrashes(View):
def index(self, *args, **kwargs):
a = b
return []
@@ -48,14 +48,13 @@ class IndexCrashes(View):
return 0
-#----------------------------------------------------------
+# ----------------------------------------------------------
class GetCrashes(View):
-
def index(self, *args, **kwargs):
- Entry = namedtuple('Entry', ['out'])
- return [ Entry(1) ]
+ Entry = namedtuple("Entry", ["out"])
+ return [Entry(1)]
def get(self, *args, **kwargs):
a = b
diff --git a/beat/backend/python/test/prefix/databases/duplicate_key_error/1.py b/beat/backend/python/test/prefix/databases/duplicate_key_error/1.py
index e7037b89f938a8ad9aa3fdf04ac047716528a287..1ffca6f03a97be87fb4cb0a76e023230a2551bee 100644
--- a/beat/backend/python/test/prefix/databases/duplicate_key_error/1.py
+++ b/beat/backend/python/test/prefix/databases/duplicate_key_error/1.py
@@ -34,9 +34,10 @@
###################################################################################
+from collections import namedtuple
+
import numpy
-from collections import namedtuple
from beat.backend.python.database import View as BaseView
diff --git a/beat/backend/python/test/prefix/databases/integers_db/1.py b/beat/backend/python/test/prefix/databases/integers_db/1.py
index f9fd5c46887d08edc45b0444b0f2438722cfe055..859044fbd84cd1aaacc97831766797d347cca0e3 100755
--- a/beat/backend/python/test/prefix/databases/integers_db/1.py
+++ b/beat/backend/python/test/prefix/databases/integers_db/1.py
@@ -34,16 +34,16 @@
###################################################################################
-import random
-import numpy
from collections import namedtuple
+
+import numpy
+
from beat.backend.python.database import View
class Double(View):
-
def index(self, root_folder, parameters):
- Entry = namedtuple('Entry', ['a', 'b', 'sum'])
+ Entry = namedtuple("Entry", ["a", "b", "sum"])
return [
Entry(1, 10, 11),
@@ -57,37 +57,27 @@ class Double(View):
Entry(9, 90, 99),
]
-
def get(self, output, index):
obj = self.objs[index]
- if output == 'a':
- return {
- 'value': numpy.int32(obj.a)
- }
+ if output == "a":
+ return {"value": numpy.int32(obj.a)}
- elif output == 'b':
- return {
- 'value': numpy.int32(obj.b)
- }
+ elif output == "b":
+ return {"value": numpy.int32(obj.b)}
- elif output == 'sum':
- return {
- 'value': numpy.int32(obj.sum)
- }
- elif output == 'class':
- return {
- 'value': numpy.int32(obj.cls)
- }
+ elif output == "sum":
+ return {"value": numpy.int32(obj.sum)}
+ elif output == "class":
+ return {"value": numpy.int32(obj.cls)}
-#----------------------------------------------------------
+# ----------------------------------------------------------
class Triple(View):
-
def index(self, root_folder, parameters):
- Entry = namedtuple('Entry', ['a', 'b', 'c', 'sum'])
+ Entry = namedtuple("Entry", ["a", "b", "c", "sum"])
return [
Entry(1, 10, 100, 111),
@@ -101,79 +91,63 @@ class Triple(View):
Entry(9, 90, 900, 999),
]
-
def get(self, output, index):
obj = self.objs[index]
- if output == 'a':
- return {
- 'value': numpy.int32(obj.a)
- }
+ if output == "a":
+ return {"value": numpy.int32(obj.a)}
- elif output == 'b':
- return {
- 'value': numpy.int32(obj.b)
- }
+ elif output == "b":
+ return {"value": numpy.int32(obj.b)}
- elif output == 'c':
- return {
- 'value': numpy.int32(obj.c)
- }
+ elif output == "c":
+ return {"value": numpy.int32(obj.c)}
- elif output == 'sum':
- return {
- 'value': numpy.int32(obj.sum)
- }
+ elif output == "sum":
+ return {"value": numpy.int32(obj.sum)}
-#----------------------------------------------------------
+# ----------------------------------------------------------
class Labelled(View):
-
def index(self, root_folder, parameters):
- Entry = namedtuple('Entry', ['label', 'value'])
+ Entry = namedtuple("Entry", ["label", "value"])
return [
- Entry('A', 1),
- Entry('A', 2),
- Entry('A', 3),
- Entry('A', 4),
- Entry('A', 5),
- Entry('B', 10),
- Entry('B', 20),
- Entry('B', 30),
- Entry('B', 40),
- Entry('B', 50),
- Entry('C', 100),
- Entry('C', 200),
- Entry('C', 300),
- Entry('C', 400),
- Entry('C', 500),
+ Entry("A", 1),
+ Entry("A", 2),
+ Entry("A", 3),
+ Entry("A", 4),
+ Entry("A", 5),
+ Entry("B", 10),
+ Entry("B", 20),
+ Entry("B", 30),
+ Entry("B", 40),
+ Entry("B", 50),
+ Entry("C", 100),
+ Entry("C", 200),
+ Entry("C", 300),
+ Entry("C", 400),
+ Entry("C", 500),
]
-
def get(self, output, index):
obj = self.objs[index]
- if output == 'label':
- return {
- 'value': obj.label
- }
+ if output == "label":
+ return {"value": obj.label}
- elif output == 'value':
- return {
- 'value': numpy.int32(obj.value)
- }
+ elif output == "value":
+ return {"value": numpy.int32(obj.value)}
-#----------------------------------------------------------
+# ----------------------------------------------------------
class DifferentFrequencies(View):
-
def index(self, root_folder, parameters):
- Entry = namedtuple('Entry', ['a', 'b'])
+ Entry = namedtuple("Entry", ["a", "b"])
return [
Entry(1, 10),
@@ -186,16 +160,11 @@ class DifferentFrequencies(View):
Entry(2, 80),
]
-
def get(self, output, index):
obj = self.objs[index]
- if output == 'a':
- return {
- 'value': numpy.int32(obj.a)
- }
+ if output == "a":
+ return {"value": numpy.int32(obj.a)}
- elif output == 'b':
- return {
- 'value': numpy.int32(obj.b)
- }
+ elif output == "b":
+ return {"value": numpy.int32(obj.b)}
diff --git a/beat/backend/python/test/prefix/databases/integers_db/2.py b/beat/backend/python/test/prefix/databases/integers_db/2.py
index 0ebebd6c4debec559f8a853830073e92a8b71bd5..859044fbd84cd1aaacc97831766797d347cca0e3 100644
--- a/beat/backend/python/test/prefix/databases/integers_db/2.py
+++ b/beat/backend/python/test/prefix/databases/integers_db/2.py
@@ -34,8 +34,10 @@
###################################################################################
-import numpy
from collections import namedtuple
+
+import numpy
+
from beat.backend.python.database import View
diff --git a/beat/backend/python/test/prefix/databases/integers_db_env/1.py b/beat/backend/python/test/prefix/databases/integers_db_env/1.py
index 0ebebd6c4debec559f8a853830073e92a8b71bd5..859044fbd84cd1aaacc97831766797d347cca0e3 100755
--- a/beat/backend/python/test/prefix/databases/integers_db_env/1.py
+++ b/beat/backend/python/test/prefix/databases/integers_db_env/1.py
@@ -34,8 +34,10 @@
###################################################################################
-import numpy
from collections import namedtuple
+
+import numpy
+
from beat.backend.python.database import View
diff --git a/beat/backend/python/test/prefix/databases/integers_db_env/2.py b/beat/backend/python/test/prefix/databases/integers_db_env/2.py
index 0ebebd6c4debec559f8a853830073e92a8b71bd5..859044fbd84cd1aaacc97831766797d347cca0e3 100644
--- a/beat/backend/python/test/prefix/databases/integers_db_env/2.py
+++ b/beat/backend/python/test/prefix/databases/integers_db_env/2.py
@@ -34,8 +34,10 @@
###################################################################################
-import numpy
from collections import namedtuple
+
+import numpy
+
from beat.backend.python.database import View
diff --git a/beat/backend/python/test/prefix/databases/python_keyword/1.py b/beat/backend/python/test/prefix/databases/python_keyword/1.py
index 34b7e83b0886273ccb45216eace1d7269c04ac0d..8011b6d5d031a1f33381fe6774e9bbb883426d08 100755
--- a/beat/backend/python/test/prefix/databases/python_keyword/1.py
+++ b/beat/backend/python/test/prefix/databases/python_keyword/1.py
@@ -34,22 +34,20 @@
###################################################################################
-import random
-import numpy
from collections import namedtuple
+
+import numpy
+
from beat.backend.python.database import View
class Keyword(View):
def __init__(self):
super(Keyword, self)
- self.output_member_map = {
- 'class': 'cls',
- 'def': 'definition'
- }
+ self.output_member_map = {"class": "cls", "def": "definition"}
def index(self, root_folder, parameters):
- Entry = namedtuple('Entry', ['cls', 'definition', 'sum'])
+ Entry = namedtuple("Entry", ["cls", "definition", "sum"])
return [
Entry(1, 10, 11),
@@ -63,21 +61,12 @@ class Keyword(View):
Entry(9, 90, 99),
]
-
def get(self, output, index):
obj = self.objs[index]
- if output == 'class':
- return {
- 'value': numpy.int32(obj.cls)
- }
- elif output == 'def':
- return {
- 'value': numpy.int32(obj.definition)
- }
- elif output == 'sum':
- return {
- 'value': numpy.int32(obj.sum)
- }
-
-
+ if output == "class":
+ return {"value": numpy.int32(obj.cls)}
+ elif output == "def":
+ return {"value": numpy.int32(obj.definition)}
+ elif output == "sum":
+ return {"value": numpy.int32(obj.sum)}
diff --git a/beat/backend/python/test/prefix/databases/with_parameters/1.py b/beat/backend/python/test/prefix/databases/with_parameters/1.py
index 8e75c18a14752b8171c5f1266f35d5b91dd30579..4df9c1ea5a551de3c7d8e46920498b67ad893897 100644
--- a/beat/backend/python/test/prefix/databases/with_parameters/1.py
+++ b/beat/backend/python/test/prefix/databases/with_parameters/1.py
@@ -34,9 +34,10 @@
###################################################################################
+from collections import namedtuple
+
import numpy
-from collections import namedtuple
from beat.backend.python.database import View as BaseView
diff --git a/beat/backend/python/test/prefix/databases/with_parameters/2.py b/beat/backend/python/test/prefix/databases/with_parameters/2.py
index 8e75c18a14752b8171c5f1266f35d5b91dd30579..4df9c1ea5a551de3c7d8e46920498b67ad893897 100644
--- a/beat/backend/python/test/prefix/databases/with_parameters/2.py
+++ b/beat/backend/python/test/prefix/databases/with_parameters/2.py
@@ -34,9 +34,10 @@
###################################################################################
+from collections import namedtuple
+
import numpy
-from collections import namedtuple
from beat.backend.python.database import View as BaseView
diff --git a/beat/backend/python/test/prefix/dataformats/user/3d_array_of_complexes/1.json b/beat/backend/python/test/prefix/dataformats/user/3d_array_of_complexes/1.json
index 5c27e0579e302c2acb0815be4fe5e1c4ebd03dd1..2587023b5acf9d20c35958c0fcae726c076d8c6f 100644
--- a/beat/backend/python/test/prefix/dataformats/user/3d_array_of_complexes/1.json
+++ b/beat/backend/python/test/prefix/dataformats/user/3d_array_of_complexes/1.json
@@ -1,4 +1,3 @@
{
"value": [5, 30, 10, "complex128"]
}
-
diff --git a/beat/backend/python/test/prefix/dataformats/user/3d_array_of_floats/1.json b/beat/backend/python/test/prefix/dataformats/user/3d_array_of_floats/1.json
index 37b52c4d9bd64f305b69389d6511ba2fa00fdadc..8f3108677e4862fa24f4a48e460ab25a43377bb7 100644
--- a/beat/backend/python/test/prefix/dataformats/user/3d_array_of_floats/1.json
+++ b/beat/backend/python/test/prefix/dataformats/user/3d_array_of_floats/1.json
@@ -1,4 +1,3 @@
{
"value": [0, 0, 0, "float64"]
}
-
diff --git a/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.json b/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.json
new file mode 100644
index 0000000000000000000000000000000000000000..a3ad982f95bc7a47d097d8a453c63453f4c92382
--- /dev/null
+++ b/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.json
@@ -0,0 +1,3 @@
+{
+ "value": "bytes"
+}
diff --git a/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.rst b/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.rst
new file mode 100644
index 0000000000000000000000000000000000000000..e62c1c42520de03eed49b89f3ed95fce122745de
--- /dev/null
+++ b/beat/backend/python/test/prefix/dataformats/user/single_bytes/1.rst
@@ -0,0 +1 @@
+Test documentation