Home
last modified time | relevance | path

Searched refs:task_arn (Results 1 – 7 of 7) sorted by relevance

/dports/devel/py-moto/moto-2.2.16/moto/datasync/
H A Dmodels.py67 self.task_arn = task_arn
183 def _get_task(self, task_arn): argument
184 if task_arn in self.tasks:
185 return self.tasks[task_arn]
190 if task_arn in self.tasks:
191 task = self.tasks[task_arn]
199 def delete_task(self, task_arn): argument
200 if task_arn in self.tasks:
201 del self.tasks[task_arn]
207 if task_arn in self.tasks:
[all …]
H A Dresponses.py99 task_arn = self._get_param("TaskArn")
101 task_arn,
121 task_arn = self._get_param("TaskArn")
122 self.datasync_backend.delete_task(task_arn)
126 task_arn = self._get_param("TaskArn")
127 task = self.datasync_backend._get_task(task_arn)
143 task_arn = self._get_param("TaskArn")
144 arn = self.datasync_backend.start_task_execution(task_arn)
159 self.datasync_backend.tasks[task_execution.task_arn].status = "AVAILABLE"
/dports/devel/py-moto/moto-2.2.16/tests/test_datasync/
H A Dtest_datasync.py217 task_arn = response["TaskArn"]
261 task_arn = response["TaskArn"]
263 assert response["TaskArn"] == task_arn
270 assert response["TaskArn"] == task_arn
292 assert task_arn is not None
294 client.delete_task(TaskArn=task_arn)
299 client.delete_task(TaskArn=task_arn)
312 task_arn = response["TaskArn"]
334 task_arn = response["TaskArn"]
354 task_arn = response["TaskArn"]
[all …]
/dports/devel/py-moto/moto-2.2.16/tests/test_dms/
H A Dtest_dms.py78 task_arn = response["ReplicationTask"]["ReplicationTaskArn"]
80 ReplicationTaskArn=task_arn, StartReplicationTaskType="start-replication"
83 Filters=[{"Name": "replication-task-arn", "Values": [task_arn],}]
118 task_arn = response["ReplicationTask"]["ReplicationTaskArn"]
121 client.stop_replication_task(ReplicationTaskArn=task_arn)
156 task_arn = response["ReplicationTask"]["ReplicationTaskArn"]
160 client.stop_replication_task(ReplicationTaskArn=task_arn)
162 Filters=[{"Name": "replication-task-arn", "Values": [task_arn],}]
180 task_arn = response["ReplicationTask"]["ReplicationTaskArn"]
181 client.delete_replication_task(ReplicationTaskArn=task_arn)
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_datadog/
H A Ddatadog_remap.c121 char *task_arn; in dd_remap_ecs_task_arn() local
140 task_arn = strstr(buf, ECS_TASK_PREFIX); in dd_remap_ecs_task_arn()
141 if (task_arn != NULL) { in dd_remap_ecs_task_arn()
143 task_arn += strlen(ECS_TASK_PREFIX); in dd_remap_ecs_task_arn()
144 dd_remap_append_kv_to_ddtags(tag_name, task_arn, strlen(task_arn), dd_tags); in dd_remap_ecs_task_arn()
/dports/net/py-libcloud/apache-libcloud-3.4.1/libcloud/container/drivers/
H A Decs.py342 def ex_start_task(self, task_arn, count=1): argument
356 'taskDefinition': task_arn}
365 containers.extend(self._to_containers(task, task_arn))
/dports/devel/py-moto/moto-2.2.16/moto/ecs/
H A Dmodels.py308 def task_arn(self): member in Task
318 response_object["taskArn"] = self.task_arn
917 self.tasks[cluster.name][task.task_arn] = task
1031 self.tasks[cluster.name][task.task_arn] = task
1041 for task_arn, task in cluster_tasks.items():
1042 task_id = task_arn.split("/")[-1]
1044 task_arn in tasks
1045 or task.task_arn in tasks
1103 return [t.task_arn for t in filtered_tasks]