|
30 | 30 | from django.core.management.base import BaseCommand |
31 | 31 | from geonode.resource.models import ExecutionRequest |
32 | 32 | from geonode.upload.handlers.base import BaseHandler |
33 | | -from geonode.upload.handlers.apps import run_setup_hooks |
34 | 33 |
|
35 | 34 |
|
36 | 35 | class Command(BaseCommand): |
@@ -122,10 +121,6 @@ def __init__( |
122 | 121 | self.overwrite_existing_layers = overwrite_existing_layers |
123 | 122 | self.skip_existing_layers = skip_existing_layers |
124 | 123 | self.tentatives = tentatives |
125 | | - print(f"Current BaseHandler registry: {BaseHandler.get_registry()}") |
126 | | - if not BaseHandler.get_registry(): |
127 | | - run_setup_hooks() |
128 | | - print(f"BaseHandler registry after setup: {BaseHandler.get_registry()}") |
129 | 124 | self.handlers = BaseHandler.get_registry() |
130 | 125 |
|
131 | 126 | def execute(self): |
@@ -163,8 +158,10 @@ def process_file(self, file_path, success, errors): |
163 | 158 | return |
164 | 159 |
|
165 | 160 | handler = self.get_handler(file_path) |
| 161 | + print(f"Handler found: {handler.__class__.__name__ if handler else 'None'}") |
166 | 162 | if not handler and not self.is_archive_file(file_path): |
167 | 163 | # Ignore unsupported files |
| 164 | + print(f"Unsupported file type: {file_path}") |
168 | 165 | return |
169 | 166 |
|
170 | 167 | if handler: |
@@ -207,6 +204,7 @@ def get_handler(self, file_path): |
207 | 204 |
|
208 | 205 | _data = {"base_file": file_path} |
209 | 206 | for handler_class in self.handlers: |
| 207 | + print(f"Checking handler: {handler_class.__name__} for file: {file_path}") |
210 | 208 | if handler_class.can_handle(_data): |
211 | 209 | return handler_class() |
212 | 210 | return None |
|
0 commit comments