Skip to content

hsfs.feature_logger_async #

AsyncFeatureLogger #

Bases: FeatureLogger

close #

close(timeout: float | None = None) -> bool

Stop admission and drain accepted rows within the shutdown deadline.

PARAMETER DESCRIPTION
timeout

Maximum time to drain, or the configured shutdown limit.

TYPE: float | None DEFAULT: None

RETURNS DESCRIPTION
bool

Whether all accepted rows finished before the deadline.