You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Asgeir Berland (JIRA)" <ji...@apache.org> on 2019/06/01 21:47:00 UTC

[jira] [Commented] (AIRFLOW-4523) Command Parameter in Azure Container Instances Operator

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

Asgeir Berland commented on AIRFLOW-4523:
-----------------------------------------

It's a documentation bug as it clearly states it takes as string and not a list. I'll update it in my next [PR|https://github.com/apache/airflow/pull/5319] along with other ACI improvements and bugfixes.

> Command Parameter in Azure Container Instances Operator
> -------------------------------------------------------
>
>                 Key: AIRFLOW-4523
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-4523
>             Project: Apache Airflow
>          Issue Type: Bug
>          Components: contrib
>    Affects Versions: 1.10.3
>            Reporter: Jonas
>            Assignee: Asgeir Berland
>            Priority: Minor
>
> Hi, i´ve got a Problem with Azure Container Instances Operator: In my DAG the 'command' Parameter will be ignored..
> I´m using Airflow 1.10.3
> Here my Operator in my DAG:
> {code:java}
> chunk_data = AzureContainerInstancesOperator(
>     ci_conn_id='azure_container_instances_default',
>     registry_conn_id='azure_registry',
>     resource_group='man-ano',
>     name='aci-echo',
>     image='mancr.azurecr.io/echo-docker:latest',
>     region='westeurope',
>     environment_variables={},
>     memory_in_gb=4.0,
>     cpu=1.0,
>     command='world',
>     task_id='aci-echo',
>     dag=dag
> )
> {code}
>  
>  
> And here the Error:
> {code:java}
> [2019-05-16 07:26:57,805] {{azure_container_instances_operator.py:162}} INFO - Starting container group with 1.0 cpu 4.0 mem
> [2019-05-16 07:26:57,806] {{azure_container_instances_operator.py:201}} INFO - Deleting container group
> [2019-05-16 07:26:57,807] {{logging_mixin.py:95}} INFO - [2019-05-16 07:26:57,806] {{log.py:114}} INFO - 2e336521-8ee7-4f3f-af7f-cb7e380a06af - TokenRequest:Getting token with client credentials.
> [2019-05-16 07:26:57,902] {{__init__.py:1580}} ERROR - Refuse str type as a valid iter type.
> Traceback (most recent call last):
>  File "/usr/local/lib/python3.6/site-packages/airflow/models/__init__.py", line 1441, in _run_raw_task
>    result = task_copy.execute(context=context)
>  File "/usr/local/lib/python3.6/site-packages/airflow/contrib/operators/azure_container_instances_operator.py", line 184, in execute
>    ci_hook.create_or_update(self.resource_group, self.name, container_group)
>  File "/usr/local/lib/python3.6/site-packages/airflow/contrib/hooks/azure_container_instance_hook.py", line 88, in create_or_update
>    container_group)
>  File "/usr/local/lib/python3.6/site-packages/azure/mgmt/containerinstance/operations/container_groups_operations.py", line 337, in create_or_update
>    **operation_config
>  File "/usr/local/lib/python3.6/site-packages/azure/mgmt/containerinstance/operations/container_groups_operations.py", line 280, in _create_or_update_initial
>    body_content = self._serialize.body(container_group, 'ContainerGroup')
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 580, in body
>    return self._serialize(data, data_type, **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 452, in _serialize
>    target_obj, data_type, **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 715, in serialize_data
>    return self._serialize(data, **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 489, in _serialize
>    new_attr = self.serialize_data(orig_attr, attr_desc['type'], **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 708, in serialize_data
>    data, data_type[1:-1], **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 783, in serialize_iter
>    serialized.append(self.serialize_data(d, iter_type, **kwargs))
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 715, in serialize_data
>    return self._serialize(data, **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 489, in _serialize
>    new_attr = self.serialize_data(orig_attr, attr_desc['type'], **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 708, in serialize_data
>    data, data_type[1:-1], **kwargs)
>  File "/usr/local/lib/python3.6/site-packages/msrest/serialization.py", line 776, in serialize_iter
>    raise SerializationError("Refuse str type as a valid iter type.")
> msrest.exceptions.SerializationError: Refuse str type as a valid iter type.
> [2019-05-16 07:26:57,907] {{__init__.py:1611}} INFO - Marking task as FAILED.
> {code}
> Does anyone has an explanation for my problem ?
> Thanks!



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