diff --git a/deploy/cr.yaml b/deploy/cr.yaml index af8bba8..5a574fd 100644 --- a/deploy/cr.yaml +++ b/deploy/cr.yaml @@ -4,7 +4,7 @@ metadata: name: example-celery-obj spec: common: - appName: celery-example + appName: celery-crd-example celeryApp: 'app:celery_app' image: example-image workerSpec: diff --git a/example/run_task.py b/example/run_task.py index 91ddde2..3102d41 100644 --- a/example/run_task.py +++ b/example/run_task.py @@ -6,5 +6,5 @@ add.delay(10, 20) add.delay(100, 20) i += 1 - if i == 1000: + if i == 10000: break diff --git a/handlers.py b/handlers.py index a5f5ca5..3602eb2 100644 --- a/handlers.py +++ b/handlers.py @@ -23,7 +23,6 @@ def create_fn(spec, name, namespace, logger, **kwargs): """ Celery custom resource creation handler """ - children_count = 0 # 1. Validation of spec val, err_msg = validate_spec(spec)