Jonas created AIRFLOW-4523:
------------------------------
Summary: 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
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)
