https://prefect.io logo
Join Slack
Powered by
Hi, we're going through and finally upgrading our ...
# ask-community
e
Hi, we're going through and finally upgrading our agent work pools to worker pools. I'm trying to use the KubernetesJob.publish_as_work_pool() as described here but getting this error (full trace in thread)
Copy code
TypeError: Value after * must be an iterable, not NoneType
Current have prefect version 2.20.0 and kubernetes version 29.0.0 installed. We've got quite a few custom deployments with various taints/tolerations and resource requests so it would be a big help for us to be able to use this shortcut.
Copy code
Traceback (most recent call last):
  File "/Users/<me>/<path>/register.py", line 56, in <module>
    KubernetesJob.load("agents-small-block").publish_as_work_pool()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 77, in inner
    raise exc
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 74, in inner
    return function(self, *args, **kwargs)
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 311, in coroutine_wrapper
    return call()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 432, in __call__
    return self.result()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 318, in result
    return self.future.result(timeout=timeout)
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 179, in result
    return self.__get_result()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
    raise self._exception
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 389, in _run_async
    result = await coro
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/infrastructure/base.py", line 133, in publish_as_work_pool
    base_job_template = await self.generate_work_pool_base_job_template()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 62, in inner
    raise exc
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 59, in inner
    return await function(self, *args, **kwargs)
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/infrastructure/kubernetes.py", line 389, in generate_work_pool_base_job_template
    job_manifest = self.build_job()
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 77, in inner
    raise exc
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/events/instrument.py", line 74, in inner
    return function(self, *args, **kwargs)
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/infrastructure/kubernetes.py", line 402, in build_job
    job_manifest = self._shortcut_customizations().apply(job_manifest)
  File "/opt/homebrew/Caskroom/miniforge/base/envs/<repo>/lib/python3.10/site-packages/prefect/infrastructure/kubernetes.py", line 588, in _shortcut_customizations
    + stable_hash(
TypeError: Value after * must be an iterable, not NoneType
Bumping this, thanks!
c
Hey Erik! Would you mind opening a GitHub issue for this and we can handle this in Github?
e
Submitted @Chris White
c
excellent thank you!
4 Views
Open in Slack
PreviousNext
Powered by