Change column type for Extended Task Meta args/kwargs

SQLite3 database driver requires unicode strings.

Column type changed to Binary instead of Text https://docs.sqlalchemy.org/en/13/core/type_basics.html#sqlalchemy.types.LargeBinary

celery/backends/database/__init__.py

@@ -8,6 +8,8 @@
 
 from vine.utils import wraps
 
+from kombu.utils.encoding import ensure_bytes
+
 from celery import states
 from celery.backends.base import BaseBackend
 from celery.exceptions import ImproperlyConfigured
@@ -134,8 +136,12 @@ def _update_result(self, task, result, state, traceback=None,
         task.traceback = traceback
         if self.app.conf.find_value_for_key('extended', 'result'):
             task.name = getattr(request, 'task_name', None)
-            task.args = self.encode(getattr(request, 'args', None))
-            task.kwargs = self.encode(getattr(request, 'kwargs', None))
+            task.args = ensure_bytes(
+                self.encode(getattr(request, 'args', None))
+            )
+            task.kwargs = ensure_bytes(
+                self.encode(getattr(request, 'kwargs', None))
+            )
             task.worker = getattr(request, 'hostname', None)
             task.retries = getattr(request, 'retries', None)
             task.queue = (

celery/backends/database/models.py

@@ -54,8 +54,8 @@ class TaskExtended(Task):
     __table_args__ = {'sqlite_autoincrement': True, 'extend_existing': True}
 
     name = sa.Column(sa.String(155), nullable=True)
-    args = sa.Column(sa.Text, nullable=True)
-    kwargs = sa.Column(sa.Text, nullable=True)
+    args = sa.Column(sa.LargeBinary, nullable=True)
+    kwargs = sa.Column(sa.LargeBinary, nullable=True)
     worker = sa.Column(sa.String(155), nullable=True)
     retries = sa.Column(sa.Integer, nullable=True)
     queue = sa.Column(sa.String(155), nullable=True)