[jira] [Commented] (AIRFLOW-6248) Should host variable in Connection class contain scheme?

["Ash Berlin-Taylor (Jira)" <ji...@apache.org>]

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

Ash Berlin-Taylor commented on AIRFLOW-6248:
--------------------------------------------

Ideally no, it shouldn't, but the the "schema" (not to be confused with "scheme") defines the connection type. It's all a bit messy.

If you fancy trying to unpick it all that would be amazing :) 

> Should host variable in Connection class contain scheme?
> --------------------------------------------------------
>
>                 Key: AIRFLOW-6248
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6248
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: models
>    Affects Versions: 1.10.6
>            Reporter: xifeng
>            Priority: Trivial
>             Fix For: 2.0.0
>
>
> In unit test, there are many snippets like:
> {code:python}
>   db.merge_conn(
>             Connection(
>                 conn_id='spark-default', conn_type='spark',
>                 host='yarn://yarn-master',
>                 extra='{"queue": "root.etl", "deploy-mode": "cluster"}')
>         )
> {code}
> host var contains scheme("yarn://")
> However, if there is a *uri* instance var in Connection, the host of Connection would not contain scheme. this is because *parse_from_uri *function.
> {code:python}
>   def parse_from_uri(self, uri):
>         uri_parts = urlparse(uri)
>         conn_type = uri_parts.scheme
>         if conn_type == 'postgresql':
>             conn_type = 'postgres'
>         elif '-' in conn_type:
>             conn_type = conn_type.replace('-', '_')
>         self.conn_type = conn_type
>         self.host = parse_netloc_to_hostname(uri_parts)
>         quoted_schema = uri_parts.path[1:]
>         self.schema = unquote(quoted_schema) if quoted_schema else quoted_schema
>         self.login = unquote(uri_parts.username) \
>             if uri_parts.username else uri_parts.username
>         self.password = unquote(uri_parts.password) \
>             if uri_parts.password else uri_parts.password
>         self.port = uri_parts.port
>         if uri_parts.query:
>             self.extra = json.dumps(dict(parse_qsl(uri_parts.query, keep_blank_values=True)))
> {code}
> So, should the host contain scheme? 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)