tree 729d8d95cc8525868226d7ba7104908ae2f07a56
parent c2369bd815943241b37feab528c912d58c1bbc80
author Ning Kang <kawaigin@gmail.com> 1596488450 -0700
committer GitHub <noreply@github.com> 1596488450 -0700
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJfKHsCCRBK7hj4Ov3rIwAAdHIIAK5Tlh1yQ7z0vgtRKCbDcJIr
 K5DS7NpXT1iShut4sqk2WZYSGRK1hUSjgREiis2nEf8kiS0Gz19TNm82jfyT1cPk
 Xi4XhCkUH52RtvzE2TQqRJ9osllYDnZH82FsClvlGwdDTef7cDhE0A8GhNS4fpMl
 YKs6JmeATteVlG0slCk0U03ZEZ4Bp82mdgqAGXt2iubys4SLZldZLO73MNOhTp2Z
 HzK+c2+KlbNlyWpymDiW1MqObm0rX+NH+ttDNTx73g44E3EA+UaDONR8xmWBlFxD
 BvO5Uzw2Yo64CGZTMSE5alrxX4ZmuNB4YMhkMR0FEL1oxaDQ6geA5aIg29tcQs0=
 =MKRP
 -----END PGP SIGNATURE-----
 

Interactive: clean up when pipeline is out of scope (#12339)

* Interactive: clean up when pipeline is out of scope

1. Completed the cleanup routine for all internal states held by the
   current interactive environment.
2. Utilized the environment inspector to determine whether a pipeline is
   out of scope: not assigned to variable and has no inspectable
   PCollections.
3. Invoked the cleanup every time the user defined pipelines in watched
   scope are refreshed.

Change-Id: Ia0791b865def88e81e7b1595b8430d3a9df9516e

* Fixed a test that didn't start a test stream server. With the new cleaning up routine, all test stream servers held by current interactive environment will be stopped in the test. If the grpc server has never been started (happens in tests), the stop operation will hang for a long time.

Change-Id: I2ae7ecf5e3ac11f32888887d82cd885fc64cc82f

Co-authored-by: Ning Kang <ningk@google.com>