Skip to content

Update

Update projections.

update_projection(stub, name, query, track_emitted_streams=None, **kwargs)

Updates a projection.

Source code in src/eventstore_grpc/projections/update.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
def update_projection(
    stub: projections_pb2_grpc.ProjectionsStub,
    name: str,
    query: str,
    track_emitted_streams: Optional[bool] = None,
    **kwargs,
) -> projections_pb2.UpdateResp:
    """Updates a projection."""
    request = projections_pb2.UpdateReq()
    options = projections_pb2.UpdateReq.Options()
    options.name = name
    options.query = query
    if track_emitted_streams is None:
        options.no_emit_options.CopyFrom(shared_pb2.Empty())
    else:
        options.emit_enabled = track_emitted_streams
    request.options.CopyFrom(options)
    response = stub.Update(request, **kwargs)
    return response