[jira] [Commented] (AIRFLOW-4580) The new version 1.10.3 has compatibility problems with custom plugins

2019-06-03 Thread will-beta (JIRA)


[ 
https://issues.apache.org/jira/browse/AIRFLOW-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855269#comment-16855269
 ] 

will-beta commented on AIRFLOW-4580:


[~wjdecorte]In our senario, the issue happens only when we were using custom 
plugins.


> The new version 1.10.3  has compatibility problems with custom plugins
> --
>
> Key: AIRFLOW-4580
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4580
> Project: Apache Airflow
>  Issue Type: Bug
>  Components: webserver
>Affects Versions: 1.10.3
>Reporter: will-beta
>Priority: Major
> Attachments: screenshot-1.png
>
>
> As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of 
> the DAGs utilizing my own plugins in the plugins folder.
>  !screenshot-1.png! 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Updated] (AIRFLOW-4580) The new version 1.10.3 has compatibility problems with custom plugins

2019-05-28 Thread will-beta (JIRA)


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

will-beta updated AIRFLOW-4580:
---
Attachment: screenshot-1.png

> The new version 1.10.3  has compatibility problems with custom plugins
> --
>
> Key: AIRFLOW-4580
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4580
> Project: Apache Airflow
>  Issue Type: Bug
>  Components: webserver
>Affects Versions: 1.10.3
>Reporter: will-beta
>Priority: Major
> Attachments: screenshot-1.png
>
>
> As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of 
> the DAG utilizing my own plugins in the plugins folder.
>  !image-2019-05-28-18-18-59-375.png! 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Updated] (AIRFLOW-4580) The new version 1.10.3 has compatibility problems with custom plugins

2019-05-28 Thread will-beta (JIRA)


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

will-beta updated AIRFLOW-4580:
---
Description: 
As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of the 
DAGs utilizing my own plugins in the plugins folder.
 !screenshot-1.png! 

  was:
As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of the 
DAG utilizing my own plugins in the plugins folder.
 !image-2019-05-28-18-18-59-375.png! 


> The new version 1.10.3  has compatibility problems with custom plugins
> --
>
> Key: AIRFLOW-4580
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4580
> Project: Apache Airflow
>  Issue Type: Bug
>  Components: webserver
>Affects Versions: 1.10.3
>Reporter: will-beta
>Priority: Major
> Attachments: screenshot-1.png
>
>
> As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of 
> the DAGs utilizing my own plugins in the plugins folder.
>  !screenshot-1.png! 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (AIRFLOW-4580) The new version 1.10.3 has compatibility problems with custom plugins

2019-05-28 Thread will-beta (JIRA)
will-beta created AIRFLOW-4580:
--

 Summary: The new version 1.10.3  has compatibility problems with 
custom plugins
 Key: AIRFLOW-4580
 URL: https://issues.apache.org/jira/browse/AIRFLOW-4580
 Project: Apache Airflow
  Issue Type: Bug
  Components: webserver
Affects Versions: 1.10.3
Reporter: will-beta


As you can see, the webserver doesn't show the Recent Tasks and Dag Runs of the 
DAG utilizing my own plugins in the plugins folder.
 !image-2019-05-28-18-18-59-375.png! 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Updated] (AIRFLOW-4066) dag_run failed while one operator is still running

2019-03-11 Thread will-beta (JIRA)


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

will-beta updated AIRFLOW-4066:
---
Description: 
 !image-2019-03-11-20-08-19-690.png! 
it's a BashOperator which has run a bash script for more than 10 minutes.

it occurs to me that once i noticed an operator failed while its preceding 
sensor was still running.

  was:
 !image-2019-03-11-20-08-19-690.png! 
it's a BashOperator which has run a bash script for more than 10 minutes.

it occurs to me that once i noticed an operator failed while its precedent 
sensor was still running.


> dag_run failed while one operator is still running
> --
>
> Key: AIRFLOW-4066
> URL: https://issues.apache.org/jira/browse/AIRFLOW-4066
> Project: Apache Airflow
>  Issue Type: Bug
>Reporter: will-beta
>Priority: Major
> Attachments: image-2019-03-11-20-08-19-690.png
>
>
>  !image-2019-03-11-20-08-19-690.png! 
> it's a BashOperator which has run a bash script for more than 10 minutes.
> it occurs to me that once i noticed an operator failed while its preceding 
> sensor was still running.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (AIRFLOW-4066) dag_run failed while one operator is still running

2019-03-11 Thread will-beta (JIRA)
will-beta created AIRFLOW-4066:
--

 Summary: dag_run failed while one operator is still running
 Key: AIRFLOW-4066
 URL: https://issues.apache.org/jira/browse/AIRFLOW-4066
 Project: Apache Airflow
  Issue Type: Bug
Reporter: will-beta
 Attachments: image-2019-03-11-20-08-19-690.png

 !image-2019-03-11-20-08-19-690.png! 
it's a BashOperator which has run a bash script for more than 10 minutes.

it occurs to me that once i noticed an operator failed while its precedent 
sensor was still running.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Commented] (AIRFLOW-3593) Allow '@' in usernames.

2019-01-29 Thread will-beta (JIRA)


[ 
https://issues.apache.org/jira/browse/AIRFLOW-3593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16755658#comment-16755658
 ] 

will-beta commented on AIRFLOW-3593:


[~jackjack10] It works! Thanks a lot!

> Allow '@' in usernames.
> ---
>
> Key: AIRFLOW-3593
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3593
> Project: Apache Airflow
>  Issue Type: Bug
>  Components: configuration
>Affects Versions: 1.10.1
>Reporter: will-beta
>Priority: Major
>
> The username provided by *Azure Database for PostgreSQL server* has a '@'.
> But *sql_alchemy_conn* and *result_backend* in the *airflow.cfg* do not allow 
> it.
> {panel:title=exception info"}
> (virtualenv-airflow) AirFlowTest@AirFlowTest:~/airflow$ airflow initdb
> [2018-12-29 11:00:40,925] {settings.py:174} INFO - setting.configure_orm(): 
> Using pool settings. pool_size=5, pool_recycle=1800
> [2018-12-29 11:00:41,418] {__init__.py:51} INFO - Using executor 
> CeleryExecutor
> DB: 
> postgresql+psycopg2://admin%40pg-test1:***@pg-test1.postgres.database.chinacloudapi.cn/airflow
> [2018-12-29 11:00:41,620] {db.py:338} INFO - Creating tables
> Traceback (most recent call last):
>   File "/home/AirFlowTest/virtualenv-airflow/bin/airflow", line 32, in 
> 
> args.func(args)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/bin/cli.py",
>  line 1011, in initdb
> db_utils.initdb(settings.RBAC)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
>  line 92, in initdb
> upgradedb()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
>  line 346, in upgradedb
> command.upgrade(config, 'heads')
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/command.py",
>  line 174, in upgrade
> script.run_env()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/script/base.py",
>  line 416, in run_env
> util.load_python_file(self.dir, 'env.py')
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/pyfiles.py",
>  line 93, in load_python_file
> module = load_module_py(module_id, path)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/compat.py",
>  line 79, in load_module_py
> mod = imp.load_source(module_id, path, fp)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
>  line 91, in 
> run_migrations_online()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
>  line 78, in run_migrations_online
> with connectable.connect() as connection:
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2091, in connect
> return self._connection_cls(self, **kwargs)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 90, in __init__
> if connection is not None else engine.raw_connection()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2177, in raw_connection
> self.pool.unique_connection, _connection)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2151, in _wrap_pool_connect
> e, dialect, self)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 1465, in _handle_dbapi_exception_noconnection
> exc_info
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/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 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2147, in _wrap_pool_connect
> return fn()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 328, in unique_connection
> return _ConnectionFairy._checkout(self)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 768, in _checkout
> fairy = _ConnectionRecord.checkout(pool)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 516, in checkout
> rec = pool._do_get()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 1140, in _do_get
> self._dec_overflow()
>   File 
> "/home/AirFlow

[jira] [Closed] (AIRFLOW-3593) Allow '@' in usernames.

2019-01-29 Thread will-beta (JIRA)


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

will-beta closed AIRFLOW-3593.
--
Resolution: Fixed

> Allow '@' in usernames.
> ---
>
> Key: AIRFLOW-3593
> URL: https://issues.apache.org/jira/browse/AIRFLOW-3593
> Project: Apache Airflow
>  Issue Type: Bug
>  Components: configuration
>Affects Versions: 1.10.1
>Reporter: will-beta
>Priority: Major
>
> The username provided by *Azure Database for PostgreSQL server* has a '@'.
> But *sql_alchemy_conn* and *result_backend* in the *airflow.cfg* do not allow 
> it.
> {panel:title=exception info"}
> (virtualenv-airflow) AirFlowTest@AirFlowTest:~/airflow$ airflow initdb
> [2018-12-29 11:00:40,925] {settings.py:174} INFO - setting.configure_orm(): 
> Using pool settings. pool_size=5, pool_recycle=1800
> [2018-12-29 11:00:41,418] {__init__.py:51} INFO - Using executor 
> CeleryExecutor
> DB: 
> postgresql+psycopg2://admin%40pg-test1:***@pg-test1.postgres.database.chinacloudapi.cn/airflow
> [2018-12-29 11:00:41,620] {db.py:338} INFO - Creating tables
> Traceback (most recent call last):
>   File "/home/AirFlowTest/virtualenv-airflow/bin/airflow", line 32, in 
> 
> args.func(args)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/bin/cli.py",
>  line 1011, in initdb
> db_utils.initdb(settings.RBAC)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
>  line 92, in initdb
> upgradedb()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
>  line 346, in upgradedb
> command.upgrade(config, 'heads')
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/command.py",
>  line 174, in upgrade
> script.run_env()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/script/base.py",
>  line 416, in run_env
> util.load_python_file(self.dir, 'env.py')
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/pyfiles.py",
>  line 93, in load_python_file
> module = load_module_py(module_id, path)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/compat.py",
>  line 79, in load_module_py
> mod = imp.load_source(module_id, path, fp)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
>  line 91, in 
> run_migrations_online()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
>  line 78, in run_migrations_online
> with connectable.connect() as connection:
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2091, in connect
> return self._connection_cls(self, **kwargs)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 90, in __init__
> if connection is not None else engine.raw_connection()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2177, in raw_connection
> self.pool.unique_connection, _connection)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2151, in _wrap_pool_connect
> e, dialect, self)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 1465, in _handle_dbapi_exception_noconnection
> exc_info
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/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 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
>  line 2147, in _wrap_pool_connect
> return fn()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 328, in unique_connection
> return _ConnectionFairy._checkout(self)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 768, in _checkout
> fairy = _ConnectionRecord.checkout(pool)
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 516, in checkout
> rec = pool._do_get()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
>  line 1140, in _do_get
> self._dec_overflow()
>   File 
> "/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/util/la

[jira] [Updated] (AIRFLOW-3593) Allow '@' in usernames.

2018-12-29 Thread will-beta (JIRA)


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

will-beta updated AIRFLOW-3593:
---
Description: 
The username provided by *Azure Database for PostgreSQL server* has a '@'.
But *sql_alchemy_conn* and *result_backend* in the *airflow.cfg* do not allow 
it.

{panel:title=exception info"}
(virtualenv-airflow) AirFlowTest@AirFlowTest:~/airflow$ airflow initdb
[2018-12-29 11:00:40,925] {settings.py:174} INFO - setting.configure_orm(): 
Using pool settings. pool_size=5, pool_recycle=1800
[2018-12-29 11:00:41,418] {__init__.py:51} INFO - Using executor CeleryExecutor
DB: 
postgresql+psycopg2://admin%40pg-test1:***@pg-test1.postgres.database.chinacloudapi.cn/airflow
[2018-12-29 11:00:41,620] {db.py:338} INFO - Creating tables
Traceback (most recent call last):
  File "/home/AirFlowTest/virtualenv-airflow/bin/airflow", line 32, in 
args.func(args)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/bin/cli.py",
 line 1011, in initdb
db_utils.initdb(settings.RBAC)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
 line 92, in initdb
upgradedb()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
 line 346, in upgradedb
command.upgrade(config, 'heads')
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/command.py",
 line 174, in upgrade
script.run_env()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/script/base.py",
 line 416, in run_env
util.load_python_file(self.dir, 'env.py')
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/pyfiles.py",
 line 93, in load_python_file
module = load_module_py(module_id, path)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/compat.py",
 line 79, in load_module_py
mod = imp.load_source(module_id, path, fp)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
 line 91, in 
run_migrations_online()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
 line 78, in run_migrations_online
with connectable.connect() as connection:
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2091, in connect
return self._connection_cls(self, **kwargs)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 90, in __init__
if connection is not None else engine.raw_connection()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2177, in raw_connection
self.pool.unique_connection, _connection)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2151, in _wrap_pool_connect
e, dialect, self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 1465, in _handle_dbapi_exception_noconnection
exc_info
  File 
"/home/AirFlowTest/virtualenv-airflow/local/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 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2147, in _wrap_pool_connect
return fn()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 328, in unique_connection
return _ConnectionFairy._checkout(self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 768, in _checkout
fairy = _ConnectionRecord.checkout(pool)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 516, in checkout
rec = pool._do_get()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 1140, in _do_get
self._dec_overflow()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/util/langhelpers.py",
 line 66, in __exit__
compat.reraise(exc_type, exc_value, exc_tb)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 1137, in _do_get
return self._create_connection()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 333, in _create_connection
return _ConnectionRecord(self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 461, in __init__
self.__connect(fi

[jira] [Updated] (AIRFLOW-3593) Allow '@' in usernames.

2018-12-29 Thread will-beta (JIRA)


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

will-beta updated AIRFLOW-3593:
---
Description: 
The username provided by *Azure Database for PostgreSQL server* has a '@'.
But *sql_alchemy_conn* and *result_backend* in the *airflow.cfg* do not allow 
it.

(virtualenv-airflow) AirFlowTest@AirFlowTest:~/airflow$ airflow initdb
[2018-12-29 11:00:40,925] {settings.py:174} INFO - setting.configure_orm(): 
Using pool settings. pool_size=5, pool_recycle=1800
[2018-12-29 11:00:41,418] {__init__.py:51} INFO - Using executor CeleryExecutor
DB: 
postgresql+psycopg2://admin%40pg-test1:***@pg-test1.postgres.database.chinacloudapi.cn/airflow
[2018-12-29 11:00:41,620] {db.py:338} INFO - Creating tables
Traceback (most recent call last):
  File "/home/AirFlowTest/virtualenv-airflow/bin/airflow", line 32, in 
args.func(args)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/bin/cli.py",
 line 1011, in initdb
db_utils.initdb(settings.RBAC)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
 line 92, in initdb
upgradedb()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/utils/db.py",
 line 346, in upgradedb
command.upgrade(config, 'heads')
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/command.py",
 line 174, in upgrade
script.run_env()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/script/base.py",
 line 416, in run_env
util.load_python_file(self.dir, 'env.py')
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/pyfiles.py",
 line 93, in load_python_file
module = load_module_py(module_id, path)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/alembic/util/compat.py",
 line 79, in load_module_py
mod = imp.load_source(module_id, path, fp)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
 line 91, in 
run_migrations_online()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/airflow/migrations/env.py",
 line 78, in run_migrations_online
with connectable.connect() as connection:
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2091, in connect
return self._connection_cls(self, **kwargs)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 90, in __init__
if connection is not None else engine.raw_connection()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2177, in raw_connection
self.pool.unique_connection, _connection)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2151, in _wrap_pool_connect
e, dialect, self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 1465, in _handle_dbapi_exception_noconnection
exc_info
  File 
"/home/AirFlowTest/virtualenv-airflow/local/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 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/engine/base.py",
 line 2147, in _wrap_pool_connect
return fn()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 328, in unique_connection
return _ConnectionFairy._checkout(self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 768, in _checkout
fairy = _ConnectionRecord.checkout(pool)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 516, in checkout
rec = pool._do_get()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 1140, in _do_get
self._dec_overflow()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/util/langhelpers.py",
 line 66, in __exit__
compat.reraise(exc_type, exc_value, exc_tb)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 1137, in _do_get
return self._create_connection()
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 333, in _create_connection
return _ConnectionRecord(self)
  File 
"/home/AirFlowTest/virtualenv-airflow/local/lib/python2.7/site-packages/sqlalchemy/pool.py",
 line 461, in __init__
self.__connect(first_connect_check=True)
  File

[jira] [Created] (AIRFLOW-3593) Allow '@' in usernames.

2018-12-29 Thread will-beta (JIRA)
will-beta created AIRFLOW-3593:
--

 Summary: Allow '@' in usernames.
 Key: AIRFLOW-3593
 URL: https://issues.apache.org/jira/browse/AIRFLOW-3593
 Project: Apache Airflow
  Issue Type: Bug
  Components: configuration
Affects Versions: 1.10.1
Reporter: will-beta


The username provided by *Azure Database for PostgreSQL server* has a '@'.
But *sql_alchemy_conn* and *result_backend* in the *airflow.cfg* do not allow 
it.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)