Queue-Related SDKs

Querying All Queues

You can use the API provided by DLI to query the queue list and select the corresponding queue to execute the job. Sample code is as follows:

1
2
3
4
5
6
7
8
9
def list_all_queues(dli_client):
    try:        
       queues = dli_client.list_queues()
    except DliException as e:
        print(e)
        return

    for queue in queues:
        print(queue.name)