Braun Reyes
@pytest.mark.usefixtures("ecs_mocks") async def test_task_customizations_as_string(aws_credentials): task = ECSTask( aws_credentials=aws_credentials, memory=512, cpu=256, task_customizations='[{"op": "replace", "path": "/overrides/cpu", "value": "512"}, {"op": "replace", "path": "/overrides/memory", "value": "1024"}]', ) # type: ignore original_run_task = task._run_task mock_run_task = MagicMock(side_effect=original_run_task) task._run_task = mock_run_task await run_then_stop_task(task) overrides = mock_run_task.call_args[0][1].get("overrides") assert overrides["memory"] == "1024" assert overrides["cpu"] == "512"
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.