resourceConnection = $resourceConnection; } /** * @param int $shipmentId * @return void */ public function execute(int $shipmentId) { $connection = $this->resourceConnection->getConnection(); $tableName = $this->resourceConnection->getTableName('inventory_shipment_source'); $connection->delete($tableName, [ self::SHIPMENT_ID . ' = ?' => $shipmentId, ]); } }