prefect.server.api.concurrency_limits
Routes for interacting with concurrency limit objects.
read_concurrency_limit(concurrency_limit_id=Path(..., description='The concurrency limit id', alias='id'), db=Depends(provide_database_interface))
async
Get a concurrency limit by id.
The active slots
field contains a list of TaskRun IDs currently using a
concurrency slot for the specified tag.
Source code in src/prefect/server/api/concurrency_limits.py
43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 |
|
read_concurrency_limit_by_tag(tag=Path(..., description='The tag name', alias='tag'), db=Depends(provide_database_interface))
async
Get a concurrency limit by tag.
The active slots
field contains a list of TaskRun IDs currently using a
concurrency slot for the specified tag.
Source code in src/prefect/server/api/concurrency_limits.py
67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 |
|
read_concurrency_limits(limit=dependencies.LimitBody(), offset=Body(0, ge=0), db=Depends(provide_database_interface))
async
Query for concurrency limits.
For each concurrency limit the active slots
field contains a list of TaskRun IDs
currently using a concurrency slot for the specified tag.
Source code in src/prefect/server/api/concurrency_limits.py
91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 |
|