Emit CURRENT_TIMESTAMP annotation

recipe_engine/unittests/run_test.py

 #!/usr/bin/env python
 # Copyright 2014 The LUCI Authors. All rights reserved.
 # Use of this source code is governed under the Apache License, Version 2.0
 # that can be found in the LICENSE file.
 
 import json
 import os
 import re
 import subprocess
 import sys
@@ skipping 114 matching lines @@
       bash_output = subprocess.check_output([
           'bash', '-c', '/bin/echo %s' % quoted])
       self.assertEqual(bash_output.decode('utf-8'), s + '\n')
 
       # zsh is untested because zsh isn't provisioned on our bots. (luqui)
       # zsh_output = subprocess.check_output([
       #     'zsh', '-c', '/bin/echo %s' % quoted])
       # self.assertEqual(zsh_output.decode('utf-8'), s + '\n')
 
   def test_run_unconsumed(self):
-    stream_engine = recipe_engine.stream.NoopStreamEngine()
-    properties = {}
+    with recipe_engine.stream.NoopStreamEngine() as stream_engine:
+      properties = {}
 
-    test_data = recipe_engine.recipe_test_api.TestData()
-    test_data.expect_exception('SomeException')
+      test_data = recipe_engine.recipe_test_api.TestData()
+      test_data.expect_exception('SomeException')
 
-    api = mock.Mock()
-    api._engine = mock.Mock()
-    api._engine.properties = properties
+      api = mock.Mock()
+      api._engine = mock.Mock()
+      api._engine.properties = properties
 
-    engine = recipe_engine.run.RecipeEngine(
-        recipe_engine.step_runner.SimulationStepRunner(
-            stream_engine, test_data),
-        properties,
-        None)
+      engine = recipe_engine.run.RecipeEngine(
+          recipe_engine.step_runner.SimulationStepRunner(
+              stream_engine, test_data),
+          properties,
+          None)
 
-    class FakeScript(object):
-      def run(self, _, __):
-        return None
+      class FakeScript(object):
+        def run(self, _, __):
+          return None
 
-    with self.assertRaises(AssertionError):
-      engine.run(FakeScript(), api)
+      with self.assertRaises(AssertionError):
+        engine.run(FakeScript(), api)
 
   def test_subannotations(self):
     proc = subprocess.Popen(
         self._run_cmd('engine_tests/subannotations'),
         stdout=subprocess.PIPE,
         stderr=subprocess.PIPE)
     stdout, _ = proc.communicate()
     self.assertRegexpMatches(stdout, r'(?m)^!@@@BUILD_STEP@steppy@@@$')
     self.assertRegexpMatches(stdout, r'(?m)^@@@BUILD_STEP@pippy@@@$')
     # Before 'Subannotate me' we expect an extra STEP_CURSOR to reset the
     # state.
     self.assertRegexpMatches(stdout,
         r'(?m)^@@@STEP_CURSOR@Subannotate me@@@\n@@@STEP_CLOSED@@@$')
 
 
 if __name__ == '__main__':
   unittest.TestCase.maxDiff = None
   unittest.main()