diff --git a/backend/src/xfd_django/xfd_api/tasks/run_syncdb.py b/backend/src/xfd_django/xfd_api/tasks/run_syncdb.py index 775066101..2bc8bc2b2 100644 --- a/backend/src/xfd_django/xfd_api/tasks/run_syncdb.py +++ b/backend/src/xfd_django/xfd_api/tasks/run_syncdb.py @@ -4,6 +4,7 @@ # Third-Party Libraries import django +from django.core.management import call_command # Set the Django settings module os.environ.setdefault("DJANGO_SETTINGS_MODULE", "xfd_django.settings") @@ -12,15 +13,6 @@ # Initialize Django django.setup() -# Third-Party Libraries -from xfd_api.tasks.syncdb_helpers import ( - drop_all_tables, - manage_elasticsearch_indices, - populate_sample_data, - sync_es_organizations, - synchronize, -) - def handler(event, context): """Trigger syncdb.""" @@ -28,34 +20,13 @@ def handler(event, context): populate = event.get("populate", False) try: - # Drop and recreate the database if dangerouslyforce is true - if dangerouslyforce: - print("Dropping and recreating the database...") - drop_all_tables() - - # Generate and apply migrations dynamically - print("Applying migrations dynamically...") - synchronize() - - # Elasticsearch Index Management - manage_elasticsearch_indices(dangerouslyforce) - - # Populate Sample Data - if populate: - print("Populating the database with sample data...") - populate_sample_data() - print("Sample data population complete.") - - # Step 4: Sync organizations in ES - - sync_es_organizations() - + call_command("syncdb", dangerouslyforce=dangerouslyforce, populate=populate) return { "statusCode": 200, "body": "Database synchronization completed successfully.", } except Exception as e: - print("Error during syncdb: {}".format(str(e))) + print("Error during syncmdl: {}".format(str(e))) return { "statusCode": 500, "body": "Database synchronization failed: {}".format(str(e)),