VictorPlusC commented on a change in pull request #16741:
URL: https://github.com/apache/beam/pull/16741#discussion_r808569344
##########
File path: sdks/python/apache_beam/runners/interactive/interactive_beam.py
##########
@@ -329,6 +332,94 @@ def record(self, pipeline):
return recording_manager.record_pipeline()
+class Clusters:
+ """An interface for users to modify the pipelines that are being run by the
+ Interactive Environment.
+
+ Methods of the Interactive Beam Clusters class can be accessed via:
+ from apache_beam.runners.interactive import interactive_beam as ib
+ ib.clusters
+
+ Example of calling the Interactive Beam clusters describe method::
+ ib.clusters.describe()
+ """
+ def __init__(self) -> None:
+ """Instantiates default values for Dataproc cluster interactions.
+ """
+ self.default_cluster_name = 'interactive-beam-cluster'
+ self.master_urls = bidict()
Review comment:
Added typehints and comments, thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
