Add preempted state checking

convoy/batch.py

@@ -351,9 +351,13 @@ def wait_for_pool_ready(batch_client, config, pool_id, addl_end_states=None):
     base_stopping_states = [
         batchmodels.ComputeNodeState.start_task_failed,
         batchmodels.ComputeNodeState.unusable,
-        batchmodels.ComputeNodeState.idle
+        batchmodels.ComputeNodeState.preempted,
+        batchmodels.ComputeNodeState.idle,
+    ]
+    base_end_states = [
+        batchmodels.ComputeNodeState.preempted,
+        batchmodels.ComputeNodeState.idle,
     ]
-    base_end_states = [batchmodels.ComputeNodeState.idle]
     if addl_end_states is not None and len(addl_end_states) > 0:
         base_stopping_states.extend(addl_end_states)
         base_end_states.extend(addl_end_states)

convoy/fleet.py

@@ -961,6 +961,13 @@ def _add_pool(
         batch.generate_docker_login_settings(config)[0])
     # create pool
     nodes = batch.create_pool(batch_client, config, pool)
+    if util.is_none_or_empty(nodes):
+        raise RuntimeError(
+            ('No nodes could be allocated for pool: {}. If the pool is '
+             'comprised entirely of low priority nodes, then there may not '
+             'have been enough available capacity in the region to satisfy '
+             'your request. Please inspect the pool for errors and issue '
+             'pool resize to try again.').format(pool.id))
     # set up gluster on compute if specified
     if gluster_on_compute:
         _setup_glusterfs(