refectoring

Author: tibut

bitflow/processingstep.py

@@ -161,7 +161,7 @@ def stop(self):
 
 class DebugGenerationStep(AsyncProcessingStep):
 	"""example generativ processing step"""
-	__name__ = "DebugGenerationStep"
+	__name__ = "debug-generation-step"
 	__description__ = "DEBUG. Generates random samples with different tages."
 
 	def __init__(self):
@@ -196,7 +196,7 @@ def stop(self):
 class Noop(ProcessingStep):
 
 	__description__ = "DEBUG. Noop."
-
+	__name__ = "noop"
 
 	def __init__(self):
 		super().__init__()
@@ -211,6 +211,7 @@ class ModifyTimestamp(ProcessingStep):
 	interval: in seconds
 	"""
 	__description__ = "Modifies Timestamp so that the first sample will get timestamp of start_time parameter"
+	__name__ = "modify-timestamp"
 
 	def __init__(self,interval : int ,start_time : str = "now"):
 		try:
@@ -238,8 +239,8 @@ class ListenForTags(ProcessingStep):
 
 	port: port to listen on
 	"""
-
 	__description__ = "Opens a rest-interface to add tags to traversing samples"
+	__name__ = "listen-for-tags"
 
 	def __init__(self,port : int = 7777):
 		from bitflow.rest import RestServer
@@ -268,8 +269,8 @@ class AddTag(ProcessingStep):
 	tag: tag name
 	value: value string 
 	"""
-
 	__description__ = "Adds a give tag and value to the samples"
+	__name__ = "add-tag"
 
 	def __init__(self, tag : str, value : str):	
 		super().__init__()

bitflow/steps/SimpleTagger.py

@@ -60,7 +60,7 @@ def main():
 	script_group.add_argument('-script',type=str,help="bitflow script. (https://github.com/bitflow-stream/antlr-grammars/tree/master/bitflow-script)")
 	script_group.add_argument("-f",help="Read given file as Bitflow Script and execute the pipeline.", metavar='')
 	script_group.add_argument("-capabilities",action='store_true',help="list all available processing steps")
-
+	#parser.add_argument("-p",help="dynamic import processing steps from a .py file")
 	ld_group = parser.add_argument_group("logging and debug")
 	ld_group.add_argument("-log",help="Redirect logs to a given file in addition to the console.",metavar='')
 	ld_group.add_argument("-v",action='store_true',help="Enable verbose logging Sink")
@@ -81,6 +81,15 @@ def main():
 		configure_logging(debug)
 		logging.debug("debug mode enabled")
 
+
+	#if args.p:
+	#	import importlib.util
+	#	file_path = args.p
+	#	module_name = '*'
+	#	spec = importlib.util.spec_from_file_location(module_name, file_path)
+	#	module = importlib.util.module_from_spec(spec)
+	#	spec.loader.exec_module(module)
+
 	if args.capabilities:
 		capabilities()
 		sys.exit(0)
@@ -90,6 +99,7 @@ def main():
 	if args.script:
 		script = args.script
 
+
 	try:
 		PIPES_INPUTS = parse_script(script)
 	except NotSupportedError as nse: