Skip to content

Delete

Delete projections.

delete_projection(stub, name, delete_emitted_streams=True, delete_state_stream=True, delete_checkpoint_stream=True, **kwargs)

Deletes a projection.

Source code in src/eventstore_grpc/projections/delete.py 
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
def delete_projection(
    stub: projections_pb2_grpc.ProjectionsStub,
    name: str,
    delete_emitted_streams: bool = True,
    delete_state_stream: bool = True,
    delete_checkpoint_stream: bool = True,
    **kwargs,
) -> projections_pb2.DeleteResp:
    """Deletes a projection."""
    request = projections_pb2.DeleteReq()
    options = projections_pb2.DeleteReq.Options()
    options.name = name
    options.delete_emitted_streams = delete_emitted_streams
    options.delete_state_stream = delete_state_stream
    options.delete_checkpoint_stream = delete_checkpoint_stream
    request.options.CopyFrom(options)
    response = stub.Delete(request, **kwargs)
    return response