summaryrefslogtreecommitdiffstats
path: root/scripts/visualize.py
diff options
context:
space:
mode:
Diffstat (limited to 'scripts/visualize.py')
-rwxr-xr-xscripts/visualize.py22
1 files changed, 3 insertions, 19 deletions
diff --git a/scripts/visualize.py b/scripts/visualize.py
index 2b828be..5685d1a 100755
--- a/scripts/visualize.py
+++ b/scripts/visualize.py
@@ -40,25 +40,9 @@ stream = trace_reader.trace_reader(traces)
40# Filter out garbage events 40# Filter out garbage events
41stream = sanitizer.sanitizer(stream) 41stream = sanitizer.sanitizer(stream)
42 42
43# Produce G-EDF error records 43# Note: You could include other submodules, to further modify
44stream = gedf_test.gedf_test(stream) 44# the event stream (e.g. produce G-EDF error records that could be
45 45# drawn by the visuazlier in future versions).
46# Produce a statistics record
47stream = stats.stats(stream)
48
49# Filter some records out
50def my_filter(record):
51 if record.record_type == 'error' and record.type_name == 'inversion_end':
52 if record.job.inversion_end - record.job.inversion_start < 4000000:
53 return False
54 return True
55#stream = filter(my_filter, stream)
56
57# It is possible to split the stream in two,
58# so we can use more than one output mechanism (for example)
59# without re-doing earlier work.
60# import itertools
61# stream1, stream2 = itertools.tee(stream,2)
62 46
63# Print the records to stdout 47# Print the records to stdout
64visualizer.visualizer(stream) 48visualizer.visualizer(stream)