Skip to content

Commit

Permalink
Remove unused send_event
Browse files Browse the repository at this point in the history
  • Loading branch information
xjules committed Oct 17, 2023
1 parent 5812488 commit acf64a7
Showing 1 changed file with 0 additions and 15 deletions.
15 changes: 0 additions & 15 deletions src/_ert_job_runner/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -127,18 +127,3 @@ async def _send(self, msg: AnyStr) -> None:

def send(self, msg: AnyStr) -> None:
self.loop.run_until_complete(self._send(msg))

def send_event(
self, ev_type: str, ev_source: str, ev_data: Optional[Dict[str, Any]] = None
) -> None:
if ev_data is None:
ev_data = {}
event = cloudevents.http.CloudEvent(
{
"type": ev_type,
"source": ev_source,
"datacontenttype": "application/json",
},
ev_data,
)
self.send(cloudevents.conversion.to_json(event).decode())

0 comments on commit acf64a7

Please sign in to comment.