Two groups of group tasks in celery, how to make the second group of tasks wait for the completion of the first group of tasks

I need to execute two sets of tasks step by step. The subtasks in each set of tasks are executed in parallel celery, but the second group of tasks needs to wait for the first group of tasks to be completed before continuing to execute

from celery import group
from tasks import add

group1 = group([add.s(2, 2), add.s(4, 4),])
group2 = group([add.s(2, 2), add.s(4, 4),])

I want the tasks in groups1 to be executed concurrently first. This requires calling groups1.apply_async () of celery, but this will make the task groups1 execute asynchronously. I want group2 to wait for group1 to execute before continuing? Is there any way to do this in celery?

Celery python

Mar.02,2021

first of all, let's analyze how many celery services you need.
the main thread is a must, so you need a thread main,
because group2 is executed after group1, so group1 and group2 should be Synchronize methods, executed in the same thread; and because they need to be asynchronous to the main thread, they should be executed in a celery.
so the final structure should be roughly as follows:

group1 corresponds to celery1, and executes
group2 corresponds to celery2, and executes
there is a celery3, group1 and group2 that Synchronize should execute in the celery, and group2 should execute
celery3 executes on main thread

roughly implement:

@app.task()
def group1():
    return group([add.s(2, 2), add.s(4, 4),])
    
@app.task()
def group2():
    return group([add.s(2, 2), add.s(4, 4),])

@app.task()
def celery3():
    result = group1.delay()
    -sharp sync group1
    result.collect()
    group2.delay()

-sharp main thread
celery3.delay()

Previous: String to JSON

Next: The image cropping and uploading component vue-image-crop-upload in vue cannot be uploaded.

Why does the task_success of celery, this signal, no longer work?
@celery_app.task(name=u"abc", routing_key="xxx") def func_abc(a, b, c, d): pass @task_success.connect(sender=u"abc") def on_abc_success(sender, result, **kwargs): pass the overall logic of the code is like this...

Celery python

Mar.05,2021
Celery multi start monitors problems with supervisor
supervisor is a process management tool under Linux, which can manage the services running in the foreground, while the services in the background need to be transformed into foreground before they can be managed through supervisor. The celery process s...

Celery python

Mar.13,2021
Does celery handle the task of updating records at the 10w level, create 10w tasks, or create a task table scan loop? What are their advantages?
the database has 10w records, which may increase to 20w in half a year, but it should not exceed 100w in the end. Server configuration: python3.6 celery+rabbitMQ CVM ubuntu 16.04 1G 1 core Database postgresql 10, with a limit of 100 connections t...

Celery python

Mar.20,2021