Queue-Related SDKs
Constraints
Jobs created using the SDK cannot run on the default queue.
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) |
For details about the dependencies and complete sample code, see Instructions.
Feedback
Was this page helpful?
Provide feedbackThank you very much for your feedback. We will continue working to improve the documentation.