additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. 8 Chapter 2. Contents Celery Documentation exceptions import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we reject it so children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 607 页 | 2.27 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 887 页 | 1.22 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 1040 页 | 1.37 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 1042 页 | 1.37 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 1057 页 | 1.35 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 1042 页 | 1.37 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to exceptions import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we reject it so children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 703 页 | 2.60 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to exceptions import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) 60 Chapter 2. Contents Celery Documentation, Release 4.1.0 children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 714 页 | 2.63 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to exceptions import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) 60 Chapter 2. Contents Celery Documentation, Release 4.0.1 children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 705 页 | 2.63 MB | 1 年前

3

additional components can be defined by the user. The worker is built up using “bootsteps” — a dependency graph enabling fine grained control of the worker’s internals. Framework Integration Celery is easy to exceptions import Reject @app.task(bind=True, acks_late=True) def render_scene(self, path): file = get_file(path) try: renderer.render_scene(file) # if the file is too big to fit in memory # we reject it so children[0].get() 64 The result instance also has a collect() method that treats the result as a graph, enabling you to iterate over the results: >>> list(res.collect()) [(

0 码力 | 701 页 | 2.59 MB | 1 年前

3