Add python client generator fixes

Author: Tommel71

clients/python/graphsense/api/addresses_api.py

@@ -33,6 +33,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -64,10 +65,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -78,6 +98,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)

clients/python/graphsense/api/blocks_api.py

@@ -11,7 +11,6 @@
 
 import warnings
 from pydantic import Field, StrictFloat, StrictStr, StrictInt
-from datetime import datetime as _datetime
 from typing import Any, Dict, List, Optional, Tuple, Union
 from typing_extensions import Annotated
 
@@ -60,7 +59,7 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
@@ -93,6 +92,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)
@@ -395,7 +401,7 @@ def _get_block_serialize(
     def get_block_by_date(
         self,
         currency: Annotated[StrictStr, Field(description="The cryptocurrency code (e.g., btc)")],
-        var_date: Annotated[Union[StrictStr, _datetime], Field(description="The date (YYYY-MM-DD)")],
+        var_date: Annotated[StrictStr, Field(description="The date (YYYY-MM-DD)")],
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -467,7 +473,7 @@ def get_block_by_date(
     def get_block_by_date_with_http_info(
         self,
         currency: Annotated[StrictStr, Field(description="The cryptocurrency code (e.g., btc)")],
-        var_date: Annotated[Union[StrictStr, _datetime], Field(description="The date (YYYY-MM-DD)")],
+        var_date: Annotated[StrictStr, Field(description="The date (YYYY-MM-DD)")],
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -539,7 +545,7 @@ def get_block_by_date_with_http_info(
     def get_block_by_date_without_preload_content(
         self,
         currency: Annotated[StrictStr, Field(description="The cryptocurrency code (e.g., btc)")],
-        var_date: Annotated[Union[StrictStr, _datetime], Field(description="The date (YYYY-MM-DD)")],
+        var_date: Annotated[StrictStr, Field(description="The date (YYYY-MM-DD)")],
         _request_timeout: Union[
             None,
             Annotated[StrictFloat, Field(gt=0)],
@@ -613,10 +619,6 @@ def _get_block_by_date_serialize(
         _host_index,
     ) -> RequestSerialized:
 
-
-        # Convert datetime to string for backward compatibility
-        if isinstance(var_date, _datetime):
-            var_date = var_date.strftime('%Y-%m-%d')
         _host = None
 
         _collection_formats: Dict[str, str] = {

clients/python/graphsense/api/bulk_api.py

@@ -24,6 +24,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -55,10 +56,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -69,6 +89,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)

clients/python/graphsense/api/entities_api.py

@@ -31,6 +31,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -62,10 +63,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -76,6 +96,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)

clients/python/graphsense/api/general_api.py

@@ -26,6 +26,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -57,10 +58,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -71,6 +91,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)

clients/python/graphsense/api/rates_api.py

@@ -24,6 +24,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -55,10 +56,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -69,6 +89,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)

clients/python/graphsense/api/tags_api.py

@@ -30,6 +30,7 @@
 
 # Backward compatibility wrapper for @validate_call to accept async_req
 from functools import wraps
+from datetime import datetime as _dt_compat
 from pydantic import ConfigDict
 _validate_call_config = ConfigDict(arbitrary_types_allowed=True)
 
@@ -61,10 +62,29 @@ def validate_call_compat(func):
     validated_func = _validate_call(config=_validate_call_config)(func)
     @wraps(func)
     def wrapper(*args, **kwargs):
-        # Remove legacy v5 kwargs that v7 doesn't support
+        # Capture async_req before removing it
         async_req = kwargs.pop('async_req', False)
         kwargs.pop('_preload_content', None)
         kwargs.pop('_return_http_data_only', None)
+        # Convert datetime to date string for date parameters (backward compatibility)
+        # Preserve full ISO 8601 format when datetime has time/timezone info
+        for key in list(kwargs.keys()):
+            if 'date' in key.lower() and isinstance(kwargs[key], _dt_compat):
+                dt = kwargs[key]
+                if dt.hour or dt.minute or dt.second or dt.tzinfo:
+                    # Preserve full datetime with timezone (ISO 8601)
+                    kwargs[key] = dt.isoformat()
+                else:
+                    # Date-only (midnight, no timezone) - use simple format
+                    kwargs[key] = dt.strftime('%Y-%m-%d')
+        # Also check positional args - var_date is typically arg[1]
+        args = list(args)
+        for i, arg in enumerate(args):
+            if isinstance(arg, _dt_compat):
+                if arg.hour or arg.minute or arg.second or arg.tzinfo:
+                    args[i] = arg.isoformat()
+                else:
+                    args[i] = arg.strftime('%Y-%m-%d')
 
         # Handle async_req: submit to thread pool if available
         if async_req:
@@ -75,6 +95,13 @@ def wrapper(*args, **kwargs):
                 if thread_pool is not None:
                     future = thread_pool.submit(validated_func, *args, **kwargs)
                     return _AsyncResult(future)
+                else:
+                    import warnings
+                    warnings.warn(
+                        "async_req=True but no thread pool available (pool_threads=0). "
+                        "Running synchronously. Set pool_threads >= 1 for async execution.",
+                        UserWarning
+                    )
             # No thread pool available, fall through to sync call
 
         return validated_func(*args, **kwargs)