airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alison Stanton (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AIRFLOW-1616) (sqlite3.OperationalError) no such table: task_instance
Date Fri, 15 Sep 2017 19:17:00 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Alison Stanton updated AIRFLOW-1616:
------------------------------------
    Description: 
I am going through the [tutorial](https://pythonhosted.org/airflow/tutorial.html) and when
I get to `airflow test tutorial print_date 2015-06-01` I start getting errors (whether the
webserver is running or not).

Specifically I get:
```
(pp_airflow) Alisons-MacBook-Air:pp-airflow alison$ airflow test tutorial templated 2017-09-15
[2017-09-15 13:58:16,638] {__init__.py:57} INFO - Using executor SequentialExecutor
/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/www/app.py:23: FlaskWTFDeprecationWarning:
"flask_wtf.CsrfProtect" has been renamed to "CSRFProtect" and will be removed in 1.0.
  csrf = CsrfProtect()
[2017-09-15 13:58:16,913] {models.py:168} INFO - Filling up the DagBag from /Users/alison/airflow/dags
Traceback (most recent call last):
  File "/Users/alison/Envs/pp_airflow/bin/airflow", line 28, in <module>
    args.func(args)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/bin/cli.py", line
585, in test
    ti.run(ignore_task_deps=True, ignore_ti_state=True, test_mode=True)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py", line
53, in wrapper
    result = func(*args, **kwargs)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py", line
1265, in run
    self.refresh_from_db(session=session, lock_for_update=True)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py", line
53, in wrapper
    result = func(*args, **kwargs)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py", line
993, in refresh_from_db
    ti = qry.with_for_update().first()
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2755, in first
    ret = list(self[0:1])
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2547, in __getitem__
    return list(res)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2855, in __iter__
    return self._execute_and_instances(context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2878, in _execute_and_instances
    result = conn.execute(querycontext.statement, self._params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 945, in execute
    return meth(self, multiparams, params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/sql/elements.py",
line 263, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1053, in _execute_clauseelement
    compiled_sql, distilled_params
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1189, in _execute_context
    context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1402, in _handle_dbapi_exception
    exc_info
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/util/compat.py",
line 203, in raise_from_cause
    reraise(type(exception), exception, tb=exc_tb, cause=cause)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1182, in _execute_context
    context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/default.py",
line 470, in do_execute
    cursor.execute(statement, parameters)
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: task_instance [SQL:
u'SELECT task_instance.task_id AS task_instance_task_id, task_instance.dag_id AS task_instance_dag_id,
task_instance.execution_date AS task_instance_execution_date, task_instance.start_date AS
task_instance_start_date, task_instance.end_date AS task_instance_end_date, task_instance.duration
AS task_instance_duration, task_instance.state AS task_instance_state, task_instance.try_number
AS task_instance_try_number, task_instance.hostname AS task_instance_hostname, task_instance.unixname
AS task_instance_unixname, task_instance.job_id AS task_instance_job_id, task_instance.pool
AS task_instance_pool, task_instance.queue AS task_instance_queue, task_instance.priority_weight
AS task_instance_priority_weight, task_instance.operator AS task_instance_operator, task_instance.queued_dttm
AS task_instance_queued_dttm, task_instance.pid AS task_instance_pid \nFROM task_instance
\nWHERE task_instance.dag_id = ? AND task_instance.task_id = ? AND task_instance.execution_date
= ?\n LIMIT ? OFFSET ?'] [parameters: ('tutorial', 'templated', '2017-09-15 00:00:00.000000',
1, 0)]
```

  was:
I am going through the [tutorial](https://pythonhosted.org/airflow/tutorial.html) and when
I get to `airflow test tutorial print_date 2015-06-01` I start getting errors (whether the
webserver is running or not).

Specifically I get:
```
(pp_airflow) Alisons-MacBook-Air:propublica-airflow alison$ airflow test tutorial templated
2017-09-15
[2017-09-15 13:58:16,638] {__init__.py:57} INFO - Using executor SequentialExecutor
/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/www/app.py:23: FlaskWTFDeprecationWarning:
"flask_wtf.CsrfProtect" has been renamed to "CSRFProtect" and will be removed in 1.0.
  csrf = CsrfProtect()
[2017-09-15 13:58:16,913] {models.py:168} INFO - Filling up the DagBag from /Users/alison/airflow/dags
Traceback (most recent call last):
  File "/Users/alison/Envs/pp_airflow/bin/airflow", line 28, in <module>
    args.func(args)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/bin/cli.py", line
585, in test
    ti.run(ignore_task_deps=True, ignore_ti_state=True, test_mode=True)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py", line
53, in wrapper
    result = func(*args, **kwargs)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py", line
1265, in run
    self.refresh_from_db(session=session, lock_for_update=True)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py", line
53, in wrapper
    result = func(*args, **kwargs)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py", line
993, in refresh_from_db
    ti = qry.with_for_update().first()
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2755, in first
    ret = list(self[0:1])
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2547, in __getitem__
    return list(res)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2855, in __iter__
    return self._execute_and_instances(context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2878, in _execute_and_instances
    result = conn.execute(querycontext.statement, self._params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 945, in execute
    return meth(self, multiparams, params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/sql/elements.py",
line 263, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1053, in _execute_clauseelement
    compiled_sql, distilled_params
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1189, in _execute_context
    context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1402, in _handle_dbapi_exception
    exc_info
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/util/compat.py",
line 203, in raise_from_cause
    reraise(type(exception), exception, tb=exc_tb, cause=cause)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1182, in _execute_context
    context)
  File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/default.py",
line 470, in do_execute
    cursor.execute(statement, parameters)
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: task_instance [SQL:
u'SELECT task_instance.task_id AS task_instance_task_id, task_instance.dag_id AS task_instance_dag_id,
task_instance.execution_date AS task_instance_execution_date, task_instance.start_date AS
task_instance_start_date, task_instance.end_date AS task_instance_end_date, task_instance.duration
AS task_instance_duration, task_instance.state AS task_instance_state, task_instance.try_number
AS task_instance_try_number, task_instance.hostname AS task_instance_hostname, task_instance.unixname
AS task_instance_unixname, task_instance.job_id AS task_instance_job_id, task_instance.pool
AS task_instance_pool, task_instance.queue AS task_instance_queue, task_instance.priority_weight
AS task_instance_priority_weight, task_instance.operator AS task_instance_operator, task_instance.queued_dttm
AS task_instance_queued_dttm, task_instance.pid AS task_instance_pid \nFROM task_instance
\nWHERE task_instance.dag_id = ? AND task_instance.task_id = ? AND task_instance.execution_date
= ?\n LIMIT ? OFFSET ?'] [parameters: ('tutorial', 'templated', '2017-09-15 00:00:00.000000',
1, 0)]
```


> (sqlite3.OperationalError) no such table: task_instance
> -------------------------------------------------------
>
>                 Key: AIRFLOW-1616
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-1616
>             Project: Apache Airflow
>          Issue Type: Bug
>    Affects Versions: 1.8.2
>         Environment: Mac OSX 10.12.6 Sierra with python 2.7, virtualenv and virtualenvwrapper
>            Reporter: Alison Stanton
>
> I am going through the [tutorial](https://pythonhosted.org/airflow/tutorial.html) and
when I get to `airflow test tutorial print_date 2015-06-01` I start getting errors (whether
the webserver is running or not).
> Specifically I get:
> ```
> (pp_airflow) Alisons-MacBook-Air:pp-airflow alison$ airflow test tutorial templated 2017-09-15
> [2017-09-15 13:58:16,638] {__init__.py:57} INFO - Using executor SequentialExecutor
> /Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/www/app.py:23: FlaskWTFDeprecationWarning:
"flask_wtf.CsrfProtect" has been renamed to "CSRFProtect" and will be removed in 1.0.
>   csrf = CsrfProtect()
> [2017-09-15 13:58:16,913] {models.py:168} INFO - Filling up the DagBag from /Users/alison/airflow/dags
> Traceback (most recent call last):
>   File "/Users/alison/Envs/pp_airflow/bin/airflow", line 28, in <module>
>     args.func(args)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/bin/cli.py",
line 585, in test
>     ti.run(ignore_task_deps=True, ignore_ti_state=True, test_mode=True)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py",
line 53, in wrapper
>     result = func(*args, **kwargs)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py",
line 1265, in run
>     self.refresh_from_db(session=session, lock_for_update=True)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/utils/db.py",
line 53, in wrapper
>     result = func(*args, **kwargs)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/airflow/models.py",
line 993, in refresh_from_db
>     ti = qry.with_for_update().first()
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2755, in first
>     ret = list(self[0:1])
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2547, in __getitem__
>     return list(res)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2855, in __iter__
>     return self._execute_and_instances(context)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/orm/query.py",
line 2878, in _execute_and_instances
>     result = conn.execute(querycontext.statement, self._params)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 945, in execute
>     return meth(self, multiparams, params)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/sql/elements.py",
line 263, in _execute_on_connection
>     return connection._execute_clauseelement(self, multiparams, params)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1053, in _execute_clauseelement
>     compiled_sql, distilled_params
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1189, in _execute_context
>     context)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1402, in _handle_dbapi_exception
>     exc_info
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/util/compat.py",
line 203, in raise_from_cause
>     reraise(type(exception), exception, tb=exc_tb, cause=cause)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
line 1182, in _execute_context
>     context)
>   File "/Users/alison/Envs/pp_airflow/lib/python2.7/site-packages/sqlalchemy/engine/default.py",
line 470, in do_execute
>     cursor.execute(statement, parameters)
> sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: task_instance
[SQL: u'SELECT task_instance.task_id AS task_instance_task_id, task_instance.dag_id AS task_instance_dag_id,
task_instance.execution_date AS task_instance_execution_date, task_instance.start_date AS
task_instance_start_date, task_instance.end_date AS task_instance_end_date, task_instance.duration
AS task_instance_duration, task_instance.state AS task_instance_state, task_instance.try_number
AS task_instance_try_number, task_instance.hostname AS task_instance_hostname, task_instance.unixname
AS task_instance_unixname, task_instance.job_id AS task_instance_job_id, task_instance.pool
AS task_instance_pool, task_instance.queue AS task_instance_queue, task_instance.priority_weight
AS task_instance_priority_weight, task_instance.operator AS task_instance_operator, task_instance.queued_dttm
AS task_instance_queued_dttm, task_instance.pid AS task_instance_pid \nFROM task_instance
\nWHERE task_instance.dag_id = ? AND task_instance.task_id = ? AND task_instance.execution_date
= ?\n LIMIT ? OFFSET ?'] [parameters: ('tutorial', 'templated', '2017-09-15 00:00:00.000000',
1, 0)]
> ```



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message