James Phoenix
@property def basepath(self) -> str: return f"gcs://{self.bucket_path}" @property def filesystem(self) -> RemoteFileSystem: settings = {} if self.service_account_info: try: settings["token"] = json.loads( self.service_account_info.get_secret_value() ) except json.JSONDecodeError: raise ValueError( "Unable to load provided service_account_info. Please make sure that the provided value is a valid JSON string." ) remote_file_system = RemoteFileSystem( basepath=f"gcs://{self.bucket_path}", settings=settings ) return remote_file_system
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.