@@ -2382,6 +2382,7 @@ def region_migrate(cls, database, environment, offering, user, hosts_zones, flag
23822382 args = "Database: {}, Environment: {}, Migration Stage: {}" .format (database , environment , migration_stage )
23832383 task_params = {
23842384 'task_name' : "region_migrate" ,
2385+ 'database' : database ,
23852386 'arguments' : args ,
23862387 }
23872388 if user :
@@ -2408,6 +2409,7 @@ def region_migrate_rollback(cls, database, user, step_manager=None, migration_st
24082409 )
24092410 task_params = {
24102411 'task_name' : "region_migrate_rollback" ,
2412+ 'database' : database ,
24112413 'arguments' : args ,
24122414 }
24132415 if user :
@@ -2509,6 +2511,7 @@ def database_migrate(
25092511 args = "Database: {}, Environment: {}, Migration Stage: {}" .format (database , new_environment , migration_stage )
25102512 task_params = {
25112513 'task_name' : "database_migrate" ,
2514+ 'database' : database ,
25122515 'arguments' : args ,
25132516 }
25142517 if user :
@@ -2537,6 +2540,7 @@ def database_migrate_rollback(cls, database, user, step_manager=None, migration_
25372540 )
25382541 task_params = {
25392542 'task_name' : "database_migrate_rollback" ,
2543+ 'database' : database ,
25402544 'arguments' : args ,
25412545 }
25422546 if user :
@@ -2563,7 +2567,6 @@ def update_database_monitoring(cls, database, hostgroup, action):
25632567 }
25642568
25652569 task = cls .create_task (task_params )
2566-
25672570 update_database_monitoring .delay (task = task , database = database , hostgroup = hostgroup , action = action ,)
25682571
25692572 @classmethod
@@ -2577,7 +2580,6 @@ def update_organization_name_monitoring(cls, database, organization_name):
25772580 }
25782581
25792582 task = cls .create_task (task_params )
2580-
25812583 update_organization_name_monitoring .delay (task = task , database = database , organization_name = organization_name )
25822584
25832585 @classmethod
@@ -2612,7 +2614,6 @@ def database_change_persistence(cls, database, user, since_step=None):
26122614 }
26132615
26142616 delay_params .update (** {'since_step' : since_step } if since_step else {})
2615-
26162617 change_database_persistence .delay (** delay_params )
26172618
26182619 @classmethod
@@ -2639,7 +2640,6 @@ def database_set_ssl_required(cls, database, user, since_step=None):
26392640 }
26402641
26412642 delay_params .update (** {'since_step' : since_step } if since_step else {})
2642-
26432643 database_set_ssl_required .delay (** delay_params )
26442644
26452645 @classmethod
@@ -2666,7 +2666,6 @@ def database_set_ssl_not_required(cls, database, user, since_step=None):
26662666 }
26672667
26682668 delay_params .update (** {'since_step' : since_step } if since_step else {})
2669-
26702669 database_set_ssl_not_required .delay (** delay_params )
26712670
26722671 # ============ END TASKS ============
0 commit comments