We've got a fun one... We've created a custom `Syn...
# flyte-connectors
a
We've got a fun one... We've created a custom
SyncAgentBase
agent w/ Flytekit 1.15.4 and ran about 1000 workflows. Of those, a handful gave us this error:
Copy code
currentAttempt done. Last Error: USER::failed to create task from agent with rpc error: code = Internal desc = failed to create edge_artifact task with error:
 Trace:

    Traceback (most recent call last):
      File "/usr/local/lib/python3.11/site-packages/flytekit/extend/backend/agent_service.py", line 102, in wrapper
        res = await func(self, request, context, *args, **kwargs)
              ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
      File "/usr/local/lib/python3.11/site-packages/flytekit/extend/backend/agent_service.py", line 121, in CreateTask
        agent.create,
        ^^^^^^^^^^^^
    AttributeError: 'EdgeArtifactAgent' object has no attribute 'create'

Message:

    AttributeError: 'EdgeArtifactAgent' object has no attribute 'create'.
What's weird is that this is in the
AsyncAgentBase
code path. So I'm wondering if there's an issue w/ looking up the agent in the registry or something? Or why we get this strange behavior.
f
Use async please
a
Is there an issue w/ sync agents in general for you to suggest this? Based on the documentation, our example is clearly a request/response model
f
no sorry maybe wrong base
things work and somethings failed right
but at scale, prefer async
sync, cannot handle too much load
a
Ok, we'll look at migrating it
thank you