Re-enable prism on pipelines with unsafe triggers when calling DirectRunner.

Author: shunping

sdks/python/apache_beam/runners/direct/direct_runner.py

@@ -121,14 +121,8 @@ def accept(self, pipeline, is_interactive):
         all_options = options.get_all_options()
         self.supported_by_prism_runner = True
         # TODO(https://github.com/apache/beam/issues/33623): Prism currently
-        # double fires on AfterCount trigger, once appropriately, and once
-        # incorrectly at the end of the window. This if condition could be
-        # more targeted, but for now we'll just ignore all unsafe triggers.
-        if pipeline.allow_unsafe_triggers:
-          self.supported_by_prism_runner = False
-        # TODO(https://github.com/apache/beam/issues/33623): Prism currently
         # does not support interactive mode
-        elif is_in_ipython() or is_interactive:
+        if is_in_ipython() or is_interactive:
           self.supported_by_prism_runner = False
         # TODO(https://github.com/apache/beam/issues/33623): Prism currently
         # does not support the update compat flag