diff --git a/flows/worker.py b/flows/worker.py index 59add6265236..49911cfd72da 100644 --- a/flows/worker.py +++ b/flows/worker.py @@ -5,7 +5,7 @@ # Checks to make sure that collections are loaded prior to attempting to start a worker def main(): subprocess.check_call( - ["python", "-m", "pip", "install", "prefect-kubernetes>0.5.0"], + ["python", "-m", "pip", "install", "prefect-kubernetes>=0.5.0"], stdout=sys.stdout, stderr=sys.stderr, )