faust.cli.clean_versions

Program faust reset used to delete local table state.

class faust.cli.clean_versions.clean_versions(ctx: Context, *args: Any, key_serializer: Optional[Union[CodecT, str]] = None, value_serializer: Optional[Union[CodecT, str]] = None, **kwargs: Any)

Delete old version directories.

Warning

This command will result in the destruction of the following files:

1. Table data for previous versions of the app.

async run() → None

Execute command.

Return type:

None

remove_old_versiondirs() → None

Remove data from old application versions from data directory.

Return type:

None

app: AppT

key_serializer: Optional[Union[CodecT, str]]

The codec used to serialize keys. Taken from instance parameters or key_serializer.

value_serialier: Optional[Union[CodecT, str]]

The codec used to serialize values. Taken from instance parameters or value_serializer.

debug: bool

quiet: bool

workdir: str

datadir: str

json: bool

logfile: str

stdout: IO

stderr: IO

args: Tuple

kwargs: Dict