don't need pcap_inputs
@@ -18,11 +18,8 @@ def callback(ch, method, properties, body):
pipeline = json.loads(body.decode('utf-8'))
worker_found = False
status = {}
- pcap_inputs = []
extra_workers = {}
for worker in workers['workers']:
- if 'pcap' in worker['inputs'] or 'pcapng' in worker['inputs']:
- pcap_inputs.append(worker['name'])
file_path = pipeline['file_path']
try:
session_id = file_path.split('/')[2]
