Skip to content

Reset

Reset projections.

reset_projection(stub, name, write_checkpoint=True, **kwargs)

Resets a projection.

Source code in src/eventstore_grpc/projections/reset.py 
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
def reset_projection(
    stub: projections_pb2_grpc.ProjectionsStub,
    name: str,
    write_checkpoint: bool = True,
    **kwargs
) -> projections_pb2.ResetResp:
    """Resets a projection."""
    request = projections_pb2.ResetReq()
    options = projections_pb2.ResetReq.Options()
    options.name = name
    options.write_checkpoint = write_checkpoint
    request.options.CopyFrom(options)
    response = stub.Reset(request, **kwargs)
    return response