def METHOD_NAME(
    self,
    timestamp: float,
    collected_credentials: Sequence[Credentials],
):
    credentials_stolen_event = CredentialsStolenEvent(
        timestamp=timestamp,
        source=self._agent_id,
        tags=SSH_COLLECTOR_EVENT_TAGS,
        stolen_credentials=collected_credentials,
    )
    self._agent_event_publisher.publish(credentials_stolen_event)